org.fusesource.stompjms.client.callback
Class Connection

java.lang.Object
  org.fusesource.stompjms.client.callback.Connection

public class Connection
extends java.lang.Object

Author:

Hiram Chirino

Method Summary

void	close(java.lang.Runnable onComplete)
StompFrame	connectedFrame()
boolean	full()
org.fusesource.hawtdispatch.DispatchQueue	getDispatchQueue()
java.lang.Throwable	getFailure()
org.fusesource.hawtbuf.AsciiBuffer	nextId()
org.fusesource.hawtbuf.AsciiBuffer	nextId(java.lang.String prefix)
boolean	offer(StompFrame frame)
Connection	receive(Callback<StompFrame> receiver)
Connection	refiller(java.lang.Runnable refiller)
void	request(StompFrame frame, Callback<StompFrame> cb)
void	resume()
void	send(StompFrame frame, Callback<java.lang.Void> cb)
void	suspend()
Transport	transport()

Methods inherited from class java.lang.Object

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

Method Detail

connectedFrame

public StompFrame connectedFrame()

transport

public Transport transport()

refiller

public Connection refiller(java.lang.Runnable refiller)

receive

public Connection receive(Callback<StompFrame> receiver)

getDispatchQueue

public org.fusesource.hawtdispatch.DispatchQueue getDispatchQueue()

resume

public void resume()

suspend

public void suspend()

close

public void close(java.lang.Runnable onComplete)

offer

public boolean offer(StompFrame frame)

full

public boolean full()

getFailure

public java.lang.Throwable getFailure()

nextId

public org.fusesource.hawtbuf.AsciiBuffer nextId()

nextId

public org.fusesource.hawtbuf.AsciiBuffer nextId(java.lang.String prefix)

request

public void request(StompFrame frame,
                    Callback<StompFrame> cb)

send

public void send(StompFrame frame,
                 Callback<java.lang.Void> cb)