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(HornetQBuffer buffer) throws HornetQStompException
HornetQStompException
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(HornetQStompException e)
Copyright © 2017 JBoss, a division of Red Hat. All rights reserved.