úÎ8ê3€B      !"#$%&'()*+,-./0123456789:;<=>?@Aj 0A record used to communicate with Stomp brokers BCaccepted stomp versions session identifier stomp server info Dframes consumer thread Esend heartbeat thread Frecieve heartbeat thread send heartbeat timeout receive heaertbeat timeout last frame sent time last frame received time G(used for atomic writes to the socket Hclosed connection flag Idisconnect receipt request Jdisconnect receipt response K,excp handler invoked by the frames consumer LStomp header as a name/ value pair Stomp frame commands Broker frame commands Client frame commands  !"#$%&'()Stomp frame record *+,-.4connect to the stomp (1.0, 1.1) broker using uri /*connect to the stomp 1.1 broker using uri 0?connect to the stomp (1.0, 1.1) broker using hostname and port 18connect to the stomp 1.1 broker using hostname and port 2closes stomp connection 3!send message to the destination.  | The header 'content-length'' is automatically set by this module. 4+send group of messages to the destination.  | The header 'content-length'' is automatically set by this module. Mcreate SEND frame 55subscribe to the destination to receive stomp frames 67unsubscribe from destination given the subscription id 7=acknowledge the consumption of a message from a subscription 8;acknowledge the rejection of a message from a subscription 9start a transaction :commit a transaction ;rollback a transaction N$opens connection to the stomp boker O(parse versions supported by the broker P0open the server socket and convert it to handle Qinitialize the new connection Rcreate the authority value S9retrieve host, port and headers from the authority value Tparse stomp uri Ustop all children threads V<Gset exception handler callback to process the exception in the consumer/heartbeats threads W6invoke the exception handler and close the connection =create consume frames thread X9For any incoming frame the user callback will be invoked Y)check receipt value in the frame headers Z send frame buffer to the server [#send batch of frames to the server \serialize frames ]unparse frame headers. c | All frames except the CONNECT and CONNECTED frames will also escape any colon or newline octets ^send buffer to the handle >receives incoming frame _reads frame from the handle `reads stomp headers abread line from handle cescape header name and value dunescape header name and value eZget heartbeats values from the client and broker headers. The receiver tolerance is 100%. fparse heartbeat gupdate heartbeat time ?)send a single newline byte to the server h0periodically send heartbeat data to the server iTperiodically check a last frame receive time and mark connection as dead if needed @fork send heartbeat thread Afork receive heartbeat thread B  !"#$%&'()*+,-./0123456789:;<=>?@AI('&%$#"! )*+,-  ./0123456789:;=><@A?B   ('&%$#"!  !"#$%&'()*+,-*+,-./0123456789:;<=>?@Aj      !"#$%&'()*++,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghij Stomp-0.1.1 Network.StompVersion Subscription Transaction MessageId DestinationHostStompUriStompException StompIOError BrokerError InvalidFrame InvalidUriConnectionError Connectionversionssessionserver sendTimeout recvTimeoutlastSendlastRecvCommandSCCC ServerCommandERRORRECEIPTMESSAGE CONNECTED ClientCommandSTOMPCONNECT DISCONNECTNACKACKABORTCOMMITBEGIN UNSUBSCRIBE SUBSCRIBESENDFramecommandheadersbodyconnectstompconnect'stomp' disconnectsendsend' subscribe unsubscribeacknackbegincommitabortsetExcpHandler startConsumer receiveFramebeat startSendBeat startRecvBeathandlelistenersendBeatrecvBeatsockLockclosed disconReq disconResp excpHandleHeader mkSendFrame mkConnectionparseVer openSocketnewConn stompAuthfromAuth processUristop defaultPort onException consumeFrames checkReceipt sendFrame sendFrames putFrameshdrToStrsendBufgetFrame readHeadersreadBodyreadLineescunescgetBeatsmkBeatbeatTime clientBeat brokerBeat