org.fusesource.stomp.client
Class CallbackConnection

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

public class CallbackConnection
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)
boolean	offer(StompFrame frame, boolean addContentLength)
CallbackConnection	receive(Callback<StompFrame> receiver)
CallbackConnection	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()
org.fusesource.hawtdispatch.transport.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 org.fusesource.hawtdispatch.transport.Transport transport()

refiller

public CallbackConnection refiller(java.lang.Runnable refiller)

receive

public CallbackConnection 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)

offer

public boolean offer(StompFrame frame,
                     boolean addContentLength)

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)