public abstract class VersionedStompFrameHandler extends Object
Modifier and Type | Field and Description |
---|---|
protected StompConnection |
connection |
protected StompDecoder |
decoder |
Modifier | Constructor and Description |
---|---|
protected |
VersionedStompFrameHandler(StompConnection connection) |
protected StompConnection connection
protected StompDecoder decoder
protected VersionedStompFrameHandler(StompConnection connection)
public static VersionedStompFrameHandler getHandler(StompConnection connection, StompVersions version)
public StompFrame decode(ActiveMQBuffer buffer) throws ActiveMQStompException
ActiveMQStompException
public boolean hasBytes()
public StompDecoder getDecoder()
public StompFrame handleFrame(StompFrame request)
public abstract StompFrame onConnect(StompFrame frame)
public abstract StompFrame onDisconnect(StompFrame frame)
public abstract StompFrame onAck(StompFrame request)
public abstract StompFrame onUnsubscribe(StompFrame request)
public abstract StompFrame onStomp(StompFrame request)
public abstract StompFrame onNack(StompFrame request)
public abstract StompFrame createStompFrame(String command)
public StompFrame onUnknown(String command)
public StompFrame handleReceipt(String receiptID)
public StompFrame onCommit(StompFrame request)
public StompFrame onSend(StompFrame frame)
public StompFrame onBegin(StompFrame frame)
public StompFrame onAbort(StompFrame request)
public StompFrame onSubscribe(StompFrame request)
public StompFrame postprocess(StompFrame request)
public StompFrame createMessageFrame(ServerMessage serverMessage, StompSubscription subscription, int deliveryCount) throws Exception
Exception
public void initDecoder(VersionedStompFrameHandler existingHandler)
existingHandler
- public void onError(ActiveMQStompException e)
Copyright © 2016 The Apache Software Foundation. All rights reserved.