org.fusesource.stomp.client
Class Stomp

java.lang.Object
  org.fusesource.stomp.client.Stomp

public class Stomp
extends java.lang.Object

Author:

Hiram Chirino

Constructor Summary

Stomp()

Stomp(java.lang.String uri)

Stomp(java.lang.String host, int port)

Stomp(java.net.URI remoteURI)

Method Summary

BlockingConnection	connectBlocking()
void	connectCallback(Callback<CallbackConnection> cb)
Future<FutureConnection>	connectFuture()
java.util.concurrent.Executor	getBlockingExecutor()
static java.util.concurrent.ThreadPoolExecutor	getBlockingThreadPool()
java.lang.String	getClientId()
java.util.Properties	getCustomHeaders()
org.fusesource.hawtdispatch.DispatchQueue	getDispatchQueue()
java.lang.String	getHost()
java.net.URI	getLocalURI()
java.lang.String	getLogin()
int	getMaxReadRate()
int	getMaxWriteRate()
java.lang.String	getPasscode()
int	getReceiveBufferSize()
java.net.URI	getRemoteURI()
int	getSendBufferSize()
javax.net.ssl.SSLContext	getSslContext()
int	getTrafficClass()
java.lang.String	getVersion()
boolean	isUseLocalHost()
void	setBlockingExecutor(java.util.concurrent.Executor blockingExecutor)
static void	setBlockingThreadPool(java.util.concurrent.ThreadPoolExecutor pool)
void	setClientId(java.lang.String clientId)
void	setCustomHeaders(java.util.Properties customHeaders)
void	setDispatchQueue(org.fusesource.hawtdispatch.DispatchQueue dispatchQueue)
void	setHost(java.lang.String host)
void	setLocalURI(java.net.URI localURI)
void	setLogin(java.lang.String login)
void	setMaxReadRate(int maxReadRate)
void	setMaxWriteRate(int maxWriteRate)
void	setPasscode(java.lang.String passcode)
void	setReceiveBufferSize(int receiveBufferSize)
void	setRemoteURI(java.net.URI remoteURI)
void	setSendBufferSize(int sendBufferSize)
void	setSslContext(javax.net.ssl.SSLContext sslContext)
void	setTrafficClass(int trafficClass)
void	setUseLocalHost(boolean useLocalHost)
void	setVersion(java.lang.String version)

Methods inherited from class java.lang.Object

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

Constructor Detail

Stomp

public Stomp()

Stomp

public Stomp(java.lang.String uri)
      throws java.net.URISyntaxException

Throws:

java.net.URISyntaxException

Stomp

public Stomp(java.lang.String host,
             int port)
      throws java.net.URISyntaxException

Throws:

java.net.URISyntaxException

Stomp

public Stomp(java.net.URI remoteURI)

Method Detail

getBlockingThreadPool

public static java.util.concurrent.ThreadPoolExecutor getBlockingThreadPool()

setBlockingThreadPool

public static void setBlockingThreadPool(java.util.concurrent.ThreadPoolExecutor pool)

connectCallback

public void connectCallback(Callback<CallbackConnection> cb)

connectFuture

public Future<FutureConnection> connectFuture()

connectBlocking

public BlockingConnection connectBlocking()
                                   throws java.io.IOException

Throws:

java.io.IOException

setRemoteURI

public void setRemoteURI(java.net.URI remoteURI)

setLogin

public void setLogin(java.lang.String login)

setPasscode

public void setPasscode(java.lang.String passcode)

setHost

public void setHost(java.lang.String host)

setVersion

public void setVersion(java.lang.String version)

setCustomHeaders

public void setCustomHeaders(java.util.Properties customHeaders)

setBlockingExecutor

public void setBlockingExecutor(java.util.concurrent.Executor blockingExecutor)

setDispatchQueue

public void setDispatchQueue(org.fusesource.hawtdispatch.DispatchQueue dispatchQueue)

setLocalURI

public void setLocalURI(java.net.URI localURI)

setMaxReadRate

public void setMaxReadRate(int maxReadRate)

setMaxWriteRate

public void setMaxWriteRate(int maxWriteRate)

setReceiveBufferSize

public void setReceiveBufferSize(int receiveBufferSize)

setSendBufferSize

public void setSendBufferSize(int sendBufferSize)

setSslContext

public void setSslContext(javax.net.ssl.SSLContext sslContext)

setTrafficClass

public void setTrafficClass(int trafficClass)

setUseLocalHost

public void setUseLocalHost(boolean useLocalHost)

setClientId

public void setClientId(java.lang.String clientId)

getBlockingExecutor

public java.util.concurrent.Executor getBlockingExecutor()

getClientId

public java.lang.String getClientId()

getCustomHeaders

public java.util.Properties getCustomHeaders()

getDispatchQueue

public org.fusesource.hawtdispatch.DispatchQueue getDispatchQueue()

getHost

public java.lang.String getHost()

getLocalURI

public java.net.URI getLocalURI()

getLogin

public java.lang.String getLogin()

getMaxReadRate

public int getMaxReadRate()

getMaxWriteRate

public int getMaxWriteRate()

getPasscode

public java.lang.String getPasscode()

getReceiveBufferSize

public int getReceiveBufferSize()

getRemoteURI

public java.net.URI getRemoteURI()

getSendBufferSize

public int getSendBufferSize()

getSslContext

public javax.net.ssl.SSLContext getSslContext()

getTrafficClass

public int getTrafficClass()

isUseLocalHost

public boolean isUseLocalHost()

getVersion

public java.lang.String getVersion()