public class STOMP extends Protocol implements Runnable
Modifier and Type | Class and Description |
---|---|
static class |
STOMP.ClientVerb |
class |
STOMP.Connection
Class which handles a connection to a client
|
static class |
STOMP.Frame |
static class |
STOMP.ServerVerb |
static class |
STOMP.StompHeader |
Modifier and Type | Field and Description |
---|---|
protected Thread |
acceptor |
protected InetAddress |
bind_addr |
protected List<STOMP.Connection> |
connections |
protected String |
endpoint |
protected String |
endpoint_addr |
protected Map<Address,String> |
endpoints |
protected boolean |
exact_destination_match |
protected boolean |
forward_non_client_generated_msgs |
protected Address |
local_addr |
static byte |
NULL_BYTE |
protected int |
port |
protected boolean |
send_info |
protected ServerSocket |
srv_sock |
protected ConcurrentMap<String,Set<STOMP.Connection>> |
subscriptions |
protected View |
view |
Constructor and Description |
---|
STOMP() |
Modifier and Type | Method and Description |
---|---|
protected void |
broadcastEndpoint() |
Object |
down(Event evt)
An event is to be sent down the stack.
|
protected String |
getAllEndpoints() |
String |
getEndpoints() |
int |
getNumConnections() |
int |
getNumSubscriptions() |
String |
getSubscriptions() |
protected void |
handleView(View view) |
static STOMP.Frame |
readFrame(DataInputStream in) |
void |
run() |
void |
start()
This method is called on a
Channel.connect(String) . |
void |
stop()
This method is called on a
Channel.disconnect() . |
Object |
up(Event evt)
An event was received from the layer below.
|
destroy, dumpStats, enableStats, getConfigurableObjects, getDownProtocol, getId, getLevel, getName, getProtocolStack, getSocketFactory, getThreadFactory, getTransport, getUpProtocol, getValue, init, isErgonomics, printStats, providedDownServices, providedUpServices, requiredDownServices, requiredUpServices, resetStatistics, resetStats, setDownProtocol, setErgonomics, setId, setLevel, setProtocolStack, setSocketFactory, setUpProtocol, setValue, setValues, statsEnabled
protected InetAddress bind_addr
protected String endpoint_addr
protected int port
protected boolean exact_destination_match
protected boolean send_info
protected boolean forward_non_client_generated_msgs
protected Address local_addr
protected ServerSocket srv_sock
protected String endpoint
protected Thread acceptor
protected final List<STOMP.Connection> connections
protected View view
protected final ConcurrentMap<String,Set<STOMP.Connection>> subscriptions
public static final byte NULL_BYTE
public int getNumConnections()
public int getNumSubscriptions()
public String getSubscriptions()
public String getEndpoints()
public void start() throws Exception
Protocol
Channel.connect(String)
. Starts work.
Protocols are connected and queues are ready to receive events.
Will be called from bottom to top. This call will replace
the START and START_OK events.start
in class Protocol
Exception
- Thrown if protocol cannot be started successfully. This will cause the ProtocolStack
to fail, so Channel.connect(String)
will throw an exceptionpublic void stop()
Protocol
Channel.disconnect()
. Stops work (e.g. by closing multicast socket).
Will be called from top to bottom. This means that at the time of the method invocation the
neighbor protocol below is still working. This method will replace the
STOP, STOP_OK, CLEANUP and CLEANUP_OK events. The ProtocolStack guarantees that
when this method is called all messages in the down queue will have been flushedpublic Object down(Event evt)
Protocol
down_prot.down()
. In case of a GET_ADDRESS event (which tries to
retrieve the stack's address from one of the bottom layers), the layer may need to send
a new response event back up the stack using up_prot.up()
.public Object up(Event evt)
Protocol
down_prot.down()
or c) the event (or another event) is sent up
the stack using up_prot.up()
.public static STOMP.Frame readFrame(DataInputStream in) throws IOException
IOException
protected void handleView(View view)
protected String getAllEndpoints()
protected void broadcastEndpoint()
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.