Stilts 0.1.0-SNAPSHOT

org.projectodd.stilts.stomp.client
Class StompClient

java.lang.Object
  extended by 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

Stilts 0.1.0-SNAPSHOT

Copyright © 2011 JBoss, a division of Red Hat, Inc.. All Rights Reserved.