org.apache.hedwig.client

Class HedwigClient

java.lang.Object

org.apache.hedwig.client.HedwigClient

All Implemented Interfaces:

Client

public class HedwigClient
extends Object
implements Client

Hedwig client uses as starting point for all communications with the Hedwig service.

See Also:

Publisher, Subscriber

Constructor Summary

Constructors

Constructor and Description
HedwigClient(ClientConfiguration cfg) Construct a hedwig client object.
HedwigClient(ClientConfiguration cfg, org.jboss.netty.channel.ChannelFactory socketFactory) Construct a hedwig client object, using a preexisting socket factory.

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Close the client and free all associated resources.
Publisher	getPublisher() Retrieve the Publisher object for the client.
Subscriber	getSubscriber() Retrieve the Subscriber object for the client.

Methods inherited from class java.lang.Object

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

Constructor Detail

HedwigClient

public HedwigClient(ClientConfiguration cfg)

Construct a hedwig client object. The configuration object should be an instance of a class which implements ClientConfiguration.

Parameters:

cfg - The client configuration.

HedwigClient

public HedwigClient(ClientConfiguration cfg,
            org.jboss.netty.channel.ChannelFactory socketFactory)

Construct a hedwig client object, using a preexisting socket factory. This is useful if you need to create many hedwig client instances.

Parameters:

cfg - The client configuration

socketFactory - A netty socket factory.

Method Detail

getPublisher

public Publisher getPublisher()

Description copied from interface: Client

Retrieve the Publisher object for the client. This object can be used to publish messages to a topic on Hedwig.

Specified by:

getPublisher in interface Client

See Also:

Publisher

getSubscriber

public Subscriber getSubscriber()

Description copied from interface: Client

Retrieve the Subscriber object for the client. This object can be used to subscribe for messages from a topic.

Specified by:

getSubscriber in interface Client

See Also:

Subscriber

close

public void close()

Description copied from interface: Client

Close the client and free all associated resources.

Specified by:

close in interface Client