public class FrameCreatingMethodProcessor extends Object implements MethodProcessor<FrameCreatingMethodProcessor.ClientAndServerChannelMethodProcessor>, ClientMethodProcessor<FrameCreatingMethodProcessor.ClientAndServerChannelMethodProcessor>, ServerMethodProcessor<FrameCreatingMethodProcessor.ClientAndServerChannelMethodProcessor>
Modifier and Type | Class and Description |
---|---|
static interface |
FrameCreatingMethodProcessor.ClientAndServerChannelMethodProcessor |
Constructor and Description |
---|
FrameCreatingMethodProcessor(ProtocolVersion protocolVersion) |
public FrameCreatingMethodProcessor(ProtocolVersion protocolVersion)
public List<AMQDataBlock> getProcessedMethods()
public void receiveConnectionStart(short versionMajor, short versionMinor, FieldTable serverProperties, byte[] mechanisms, byte[] locales)
receiveConnectionStart
in interface ClientMethodProcessor<FrameCreatingMethodProcessor.ClientAndServerChannelMethodProcessor>
public void receiveConnectionStartOk(FieldTable clientProperties, AMQShortString mechanism, byte[] response, AMQShortString locale)
receiveConnectionStartOk
in interface ServerMethodProcessor<FrameCreatingMethodProcessor.ClientAndServerChannelMethodProcessor>
public void receiveConnectionSecure(byte[] challenge)
receiveConnectionSecure
in interface ClientMethodProcessor<FrameCreatingMethodProcessor.ClientAndServerChannelMethodProcessor>
public void receiveConnectionSecureOk(byte[] response)
receiveConnectionSecureOk
in interface ServerMethodProcessor<FrameCreatingMethodProcessor.ClientAndServerChannelMethodProcessor>
public void receiveConnectionTune(int channelMax, long frameMax, int heartbeat)
receiveConnectionTune
in interface ClientMethodProcessor<FrameCreatingMethodProcessor.ClientAndServerChannelMethodProcessor>
public void receiveConnectionTuneOk(int channelMax, long frameMax, int heartbeat)
receiveConnectionTuneOk
in interface ServerMethodProcessor<FrameCreatingMethodProcessor.ClientAndServerChannelMethodProcessor>
public void receiveConnectionOpen(AMQShortString virtualHost, AMQShortString capabilities, boolean insist)
receiveConnectionOpen
in interface ServerMethodProcessor<FrameCreatingMethodProcessor.ClientAndServerChannelMethodProcessor>
public void receiveConnectionOpenOk(AMQShortString knownHosts)
receiveConnectionOpenOk
in interface ClientMethodProcessor<FrameCreatingMethodProcessor.ClientAndServerChannelMethodProcessor>
public void receiveConnectionRedirect(AMQShortString host, AMQShortString knownHosts)
receiveConnectionRedirect
in interface ClientMethodProcessor<FrameCreatingMethodProcessor.ClientAndServerChannelMethodProcessor>
public void receiveConnectionClose(int replyCode, AMQShortString replyText, int classId, int methodId)
receiveConnectionClose
in interface MethodProcessor<FrameCreatingMethodProcessor.ClientAndServerChannelMethodProcessor>
public void receiveConnectionCloseOk()
receiveConnectionCloseOk
in interface MethodProcessor<FrameCreatingMethodProcessor.ClientAndServerChannelMethodProcessor>
public void receiveChannelOpen(int channelId)
receiveChannelOpen
in interface ServerMethodProcessor<FrameCreatingMethodProcessor.ClientAndServerChannelMethodProcessor>
public void receiveHeartbeat()
receiveHeartbeat
in interface MethodProcessor<FrameCreatingMethodProcessor.ClientAndServerChannelMethodProcessor>
public ProtocolVersion getProtocolVersion()
getProtocolVersion
in interface MethodProcessor<FrameCreatingMethodProcessor.ClientAndServerChannelMethodProcessor>
public FrameCreatingMethodProcessor.ClientAndServerChannelMethodProcessor getChannelMethodProcessor(int channelId)
getChannelMethodProcessor
in interface MethodProcessor<FrameCreatingMethodProcessor.ClientAndServerChannelMethodProcessor>
public void setProtocolVersion(ProtocolVersion protocolVersion)
public void receiveProtocolHeader(ProtocolInitiation protocolInitiation)
receiveProtocolHeader
in interface MethodProcessor<FrameCreatingMethodProcessor.ClientAndServerChannelMethodProcessor>
public void setCurrentMethod(int classId, int methodId)
setCurrentMethod
in interface MethodProcessor<FrameCreatingMethodProcessor.ClientAndServerChannelMethodProcessor>
public boolean ignoreAllButCloseOk()
ignoreAllButCloseOk
in interface MethodProcessor<FrameCreatingMethodProcessor.ClientAndServerChannelMethodProcessor>
public int getClassId()
public int getMethodId()
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.