org.projectodd.stilts.stomp.client
Class StompClient

java.lang.Object
  org.projectodd.stilts.stomp.client.StompClient

public class StompClient
extends Object

Nested Class Summary

static class

StompClient.State

Field Summary

static long	DEFAULT_CONNECT_WAIT_TIME
static long	DEFAULT_DISCONNECT_WAIT_TIME

Constructor Summary

StompClient(String uri)

StompClient(URI uri)

Method Summary

void	abort(String transactionId)
ClientTransaction	begin()
void	close()
void	commit(String transactionId)
void	connect()
void	connect(long waitTime)
protected org.jboss.netty.channel.socket.ClientSocketChannelFactory	createChannelFactory()
protected org.jboss.netty.channel.ChannelPipelineFactory	createPipelineFactory()
void	disconnect()
void	disconnect(long waitTime)
StompClient.State	getConnectionState()
Executor	getExecutor()
StompFrame.Version	getVersion()
boolean	isConnected()
boolean	isDisconnected()
void	send(StompMessage message)
void	setExecutor(Executor executor)
SubscriptionBuilder	subscribe(String destination)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_CONNECT_WAIT_TIME

public static final long DEFAULT_CONNECT_WAIT_TIME

See Also:

Constant Field Values

DEFAULT_DISCONNECT_WAIT_TIME

public static final long DEFAULT_DISCONNECT_WAIT_TIME

See Also:

Constant Field Values

Constructor Detail

StompClient

public StompClient(String uri)
            throws URISyntaxException

Throws:

URISyntaxException

StompClient

public StompClient(URI uri)
            throws URISyntaxException

Throws:

URISyntaxException

Method Detail

setExecutor

public void setExecutor(Executor executor)

getExecutor

public Executor getExecutor()

getVersion

public StompFrame.Version getVersion()

isConnected

public boolean isConnected()

isDisconnected

public boolean isDisconnected()

getConnectionState

public StompClient.State getConnectionState()

connect

public void connect()
             throws InterruptedException,
                    StompException

Throws:

InterruptedException

StompException

connect

public void connect(long waitTime)
             throws InterruptedException,
                    StompException

Throws:

InterruptedException

StompException

disconnect

public void disconnect()
                throws InterruptedException,
                       StompException

Throws:

InterruptedException

StompException

disconnect

public void disconnect(long waitTime)
                throws InterruptedException,
                       StompException

Throws:

InterruptedException

StompException

subscribe

public SubscriptionBuilder subscribe(String destination)

send

public void send(StompMessage message)

begin

public ClientTransaction begin()
                        throws StompException

Throws:

StompException

abort

public void abort(String transactionId)
           throws StompException

Throws:

StompException

commit

public void commit(String transactionId)
            throws StompException

Throws:

StompException

createPipelineFactory

protected org.jboss.netty.channel.ChannelPipelineFactory createPipelineFactory()

createChannelFactory

protected org.jboss.netty.channel.socket.ClientSocketChannelFactory createChannelFactory()

close

public void close()
           throws InterruptedException

Throws:

InterruptedException