Modifier and Type | Field and Description |
---|---|
protected HChannelManager |
channelManager |
protected boolean |
ownChannelFactory |
protected org.jboss.netty.channel.ChannelFactory |
socketFactory |
Modifier | Constructor and Description |
---|---|
protected |
HedwigClientImpl(ClientConfiguration cfg) |
protected |
HedwigClientImpl(ClientConfiguration cfg,
org.jboss.netty.channel.ChannelFactory socketFactory) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Close the client and free all associated resources.
|
static Client |
create(ClientConfiguration cfg) |
static Client |
create(ClientConfiguration cfg,
org.jboss.netty.channel.ChannelFactory socketFactory) |
ClientConfiguration |
getConfiguration() |
HChannelManager |
getHChannelManager() |
HedwigPublisher |
getPublisher()
Retrieve the Publisher object for the client.
|
HedwigSubscriber |
getSubscriber()
Retrieve the Subscriber object for the client.
|
protected void |
setSubscriber(HedwigSubscriber sub) |
protected final org.jboss.netty.channel.ChannelFactory socketFactory
protected boolean ownChannelFactory
protected final HChannelManager channelManager
protected HedwigClientImpl(ClientConfiguration cfg)
protected HedwigClientImpl(ClientConfiguration cfg, org.jboss.netty.channel.ChannelFactory socketFactory)
public static Client create(ClientConfiguration cfg)
public static Client create(ClientConfiguration cfg, org.jboss.netty.channel.ChannelFactory socketFactory)
public ClientConfiguration getConfiguration()
public HChannelManager getHChannelManager()
public HedwigSubscriber getSubscriber()
Client
getSubscriber
in interface Client
Subscriber
protected void setSubscriber(HedwigSubscriber sub)
public HedwigPublisher getPublisher()
Client
getPublisher
in interface Client
Publisher
Copyright © 2011–2019 The Apache Software Foundation. All rights reserved.