org.apache.hedwig.client.netty

Class NetUtils

java.lang.Object

org.apache.hedwig.client.netty.NetUtils

public class NetUtils
extends Object

Utilities for network operations.

Constructor Summary

Constructors

Constructor and Description
NetUtils()

Method Summary

Modifier and Type	Method and Description
static PubSubProtocol.PubSubRequest.Builder	buildConsumeRequest(long txnId, TopicSubscriber topicSubscriber, PubSubProtocol.MessageSeqId messageSeqId) Build consume request
static PubSubProtocol.PubSubRequest.Builder	buildPubSubRequest(long txnId, PubSubData pubSubData) This is a helper method to build the actual pub/sub message.
static InetSocketAddress	getHostFromChannel(org.jboss.netty.channel.Channel channel) Helper static method to get the String Hostname:Port from a netty Channel.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

NetUtils

public NetUtils()

Method Detail

getHostFromChannel

public static InetSocketAddress getHostFromChannel(org.jboss.netty.channel.Channel channel)

Helper static method to get the String Hostname:Port from a netty Channel. Assumption is that the netty Channel was originally created with an InetSocketAddress. This is true with the Hedwig netty implementation.

Parameters:

channel - Netty channel to extract the hostname and port from.

Returns:

String representation of the Hostname:Port from the Netty Channel

buildPubSubRequest

public static PubSubProtocol.PubSubRequest.Builder buildPubSubRequest(long txnId,
                                                                      PubSubData pubSubData)

This is a helper method to build the actual pub/sub message.

Parameters:

txnId - Transaction Id.

pubSubData - Publish call's data wrapper object.

Returns:

pub sub request to send

buildConsumeRequest

public static PubSubProtocol.PubSubRequest.Builder buildConsumeRequest(long txnId,
                                                                       TopicSubscriber topicSubscriber,
                                                                       PubSubProtocol.MessageSeqId messageSeqId)

Build consume request

Parameters:

txnId - Transaction Id.

topicSubscriber - Topic Subscriber.

messageSeqId - Message Seq Id.

Returns:

pub/sub request.