| Package | Description |
|---|---|
| org.fusesource.stomp.client | |
| org.fusesource.stomp.codec | |
| org.fusesource.stomp.jms | |
| org.fusesource.stomp.jms.message | |
| org.fusesource.stomp.jms.util |
| Modifier and Type | Method and Description |
|---|---|
StompFrame |
FutureConnection.connectedFrame() |
StompFrame |
CallbackConnection.connectedFrame() |
StompFrame |
BlockingConnection.connectedFrame() |
StompFrame |
BlockingConnection.receive() |
StompFrame |
BlockingConnection.request(StompFrame frame) |
| Modifier and Type | Method and Description |
|---|---|
Future<StompFrame> |
FutureConnection.receive() |
Future<StompFrame> |
FutureConnection.request(StompFrame frame) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
CallbackConnection.offer(StompFrame frame) |
boolean |
CallbackConnection.offer(StompFrame frame,
boolean addContentLength) |
Future<StompFrame> |
FutureConnection.request(StompFrame frame) |
StompFrame |
BlockingConnection.request(StompFrame frame) |
void |
CallbackConnection.request(StompFrame frame,
Callback<StompFrame> cb) |
Future<java.lang.Void> |
FutureConnection.send(StompFrame frame) |
void |
BlockingConnection.send(StompFrame frame) |
void |
CallbackConnection.send(StompFrame frame,
Callback<java.lang.Void> cb) |
| Modifier and Type | Method and Description |
|---|---|
CallbackConnection |
CallbackConnection.receive(Callback<StompFrame> receiver) |
void |
CallbackConnection.request(StompFrame frame,
Callback<StompFrame> cb) |
| Modifier and Type | Method and Description |
|---|---|
StompFrame |
StompFrame.action(org.fusesource.hawtbuf.AsciiBuffer action) |
StompFrame |
StompFrame.clone() |
StompFrame |
StompFrame.content(org.fusesource.hawtbuf.Buffer content) |
| Modifier and Type | Method and Description |
|---|---|
StompFrame |
StompServerAdaptor.createCreditFrame(StompJmsMessageConsumer consumer,
StompFrame messageFrame) |
StompFrame |
ApolloServerAdaptor.createCreditFrame(StompJmsMessageConsumer consumer,
StompFrame messageFrame) |
StompFrame |
StompServerAdaptor.createUnsubscribeFrame(org.fusesource.hawtbuf.AsciiBuffer consumerId,
boolean persistent) |
StompFrame |
ApolloServerAdaptor.createUnsubscribeFrame(org.fusesource.hawtbuf.AsciiBuffer consumerId,
boolean persistent) |
| Modifier and Type | Method and Description |
|---|---|
StompFrame |
StompServerAdaptor.createCreditFrame(StompJmsMessageConsumer consumer,
StompFrame messageFrame) |
StompFrame |
ApolloServerAdaptor.createCreditFrame(StompJmsMessageConsumer consumer,
StompFrame messageFrame) |
void |
StompChannel.onFrame(StompFrame frame) |
void |
StompChannel.sendFrame(StompFrame frame) |
void |
StompChannel.sendRequest(StompFrame frame) |
void |
StompChannel.sendRequest(StompFrame frame,
Promise<StompFrame> future) |
| Modifier and Type | Method and Description |
|---|---|
void |
StompChannel.ackMessage(org.fusesource.hawtbuf.AsciiBuffer consumerId,
org.fusesource.hawtbuf.AsciiBuffer messageId,
org.fusesource.hawtbuf.AsciiBuffer txid,
Promise<StompFrame> callback) |
void |
StompChannel.sendRequest(StompFrame frame,
Promise<StompFrame> future) |
| Modifier and Type | Field and Description |
|---|---|
protected StompFrame |
StompJmsMessage.frame |
| Modifier and Type | Method and Description |
|---|---|
StompFrame |
StompJmsMessage.getFrame() |
| Modifier and Type | Method and Description |
|---|---|
void |
StompJmsMessage.setFrame(StompFrame frame) |
| Modifier and Type | Method and Description |
|---|---|
static StompJmsMessage |
StompTranslator.convert(StompFrame frame) |
Copyright © 2010-2013 FuseSource, Corp.. All Rights Reserved.