org.projectodd.stilts.stomp.client
Class StompClient
java.lang.Object
org.projectodd.stilts.stomp.client.StompClient
public class StompClient
- extends Object
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
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
StompClient
public StompClient(String uri)
throws URISyntaxException
- Throws:
URISyntaxException
StompClient
public StompClient(URI uri)
throws URISyntaxException
- Throws:
URISyntaxException
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
Copyright © 2011 JBoss, a division of Red Hat, Inc.. All Rights Reserved.