Table of Contents - stomp-1.3.5 Documentation
Pages
CHANGELOG
1.3.5 20160302
1.3.4 20141202
1.3.3 20140810
1.3.2 20131208
1.3.1 20131002
1.3.0 20130930
1.2.16 20130812
1.2.15 20130809
1.2.14 20130819
1.2.13 20130817
1.2.12 20130811
1.2.11 20130728
1.2.10 20130708
1.2.9 20130328
1.2.8 20121228
1.2.7 20121102
1.2.6 20120913
1.2.5 20120804
1.2.4 20120625
1.2.3 20120616
1.2.2 20120324
1.2.1 20120313
1.2.0 20111214
1.1.10 20111107
1.1.9 20110615
1.1.8 20110316
1.1.7 20110109
1.1.6 20100610
1.1.5 20100317
1.1.4 20100121
1.1.3 20091124
1.1 20090227
1.0.6 20080805
v1.0.5 20070201
v1.0.4 20070115
v1.0.3 20070114
v1.0.2 20060922
v1.0.1 20051217
v1.0.0 20051015
LICENSE
README
README
Overview
Hash Login Example Usage (this is the recommended login technique)
Positional Parameter Usage
Stomp URL Usage
Failover + SSL Example URL Usage
New
Historical Information
Source Code and Project URLs
Stomp Protocol Information :
Contributors
Classes/Modules
Client11Example1
Stomp 1.1 Client Example 1
Client11PutGet1
Stomp 1.1 Client Putter/Getter Example 1
Connection11Example1
Stomp 1.1 Connection Example 1
Connection11Example2
Stomp 1.1 Connection Example 2
ExampleConsumer
Example message consumer.
ExamplePublisher
Example message publisher
ExampleRubyCiphers
Example: Use Ruby Supplied Ciphers
ExampleSSL1
SSL Use Case 1 - server does not authenticate client, client does not authenticate server
ExampleSSL1C
SSL Use Case 1 - User Supplied Ciphers
ExampleSSL2
SSL Use Case 2 - server does not authenticate client, client does authenticate server
ExampleSSL2C
SSL Use Case 2 - User Supplied Ciphers
ExampleSSL3
SSL Use Case 3 - server does authenticate client, client does not authenticate server
ExampleSSL3C
SSL Use Case 3 - User Supplied Ciphers
ExampleSSL4
SSL Use Case 4 - server does authenticate client, client does authenticate server
ExampleSSL4C
SSL Use Case 4 - User Supplied Ciphers
ExampleSSLCtxOptions
Demo User Control of SSLContext options contents
ExampleSSLNewParm
Demo override of SSLContext.new parameters.
ExampleTopicConsumer
Example topic consumer.
ExampleTopicPublisher
Example topic publisher.
Hash
HeartBeatExample1
Stomp 1.1 Heartbeat Example 1
LoggerExample
A STOMP::Connection program which uses the callback logging facility.
Object
Publish11Example1
Stomp 1.1 Publish Example
Receive11Example1
Stomp 1.1 Receive Example 1
Receive11Example2
Stomp 1.1 Receive Example 2
RepeatedHeadersExample
Stomp 1.1 Send/Receive Example - Repeated Headers
SSLLoggerExample
A STOMP::Connection program which uses the callback logging facility.
Slogger
Example STOMP call back logger class.
Example STOMP call back logger class.
Stomp
Stomp11Common
Stomp::Client
Stomp::Connection
Stomp::Error
Stomp::Error::BrokerException
Stomp::Error::ConnectReadTimeout
Stomp::Error::DuplicateSubscription
Stomp::Error::InvalidFormat
Stomp::Error::InvalidHeartBeatHeaderError
Stomp::Error::InvalidMessageLength
Stomp::Error::InvalidServerCommand
Stomp::Error::LoggerConnectionError
Stomp::Error::MalformedFailoverOptionsError
Stomp::Error::MaxReconnectAttempts
Stomp::Error::MessageIDRequiredError
Stomp::Error::NilMessageError
Stomp::Error::NoCurrentConnection
Stomp::Error::PacketParsingTimeout
Stomp::Error::ProducerFlowControlException
Stomp::Error::ProtocolError11p
Stomp::Error::ProtocolErrorConnect
Stomp::Error::ProtocolErrorEmptyHeaderKey
Stomp::Error::ProtocolErrorEmptyHeaderValue
Stomp::Error::ProtocolException
Stomp::Error::ReadReceiptTimeoutException
Stomp::Error::SSLClientParamsError
Stomp::Error::SSLNoCertFileError
Stomp::Error::SSLNoKeyFileError
Stomp::Error::SSLNoTruststoreFileError
Stomp::Error::SSLUnreadableCertFileError
Stomp::Error::SSLUnreadableKeyFileError
Stomp::Error::SSLUnreadableTruststoreFileError
Stomp::Error::SocketOpenTimeout
Stomp::Error::StartTimeoutException
Stomp::Error::StompException
Stomp::Error::StompServerError
Stomp::Error::SubscriptionRequiredError
Stomp::Error::UTF8ValidationError
Stomp::Error::UnsupportedProtocolError
Stomp::HeaderCodec
Purpose
Stomp::Message
Stomp::NullLogger
Stomp::SSLParams
Purpose
Stomp::Version
TestAnonymous
TestBase
TestClient
TestCodec
TestConnection
TestConnection1P
TestMessage
TestSSL
TestURLLogins
Tlogger
Methods
::decode — Stomp::HeaderCodec
::default_port — Stomp::Connection
::encode — Stomp::HeaderCodec
::new — ExampleTopicConsumer
::new — Connection11Example1
::new — ExampleTopicPublisher
::new — Connection11Example2
::new — Tlogger
::new — HeartBeatExample1
::new — Stomp::SSLParams
::new — ExampleConsumer
::new — Stomp::Message
::new — Slogger
::new — ExampleSSL2C
::new — Stomp::Error::ReadReceiptTimeoutException
::new — Receive11Example2
::new — Stomp::Error::ProtocolException
::new — Stomp::Error::ProducerFlowControlException
::new — Stomp::Error::BrokerException
::new — ExampleSSL1C
::new — Client11Example1
::new — Client11PutGet1
::new — ExampleSSL1
::new — ExampleRubyCiphers
::new — ExampleSSL4C
::new — ExampleSSL2
::new — ExampleSSL4
::new — ExampleSSLNewParm
::new — ExampleSSL3
::new — Stomp::Connection
::new — ExampleSSLCtxOptions
::new — Stomp::Client
::new — RepeatedHeadersExample
::new — Publish11Example1
::new — ExamplePublisher
::new — ExampleSSL3C
::new — SSLLoggerExample
::new — Receive11Example1
::new — LoggerExample
::new — Stomp::Error::StartTimeoutException
::open — Stomp::Connection
::open — Stomp::Client
::ssl_v2xoptions — Stomp::Connection
#__old_receive — Stomp::Connection
#_decodeHeaders — Stomp::Connection
#_dump_ctx — Stomp::Connection
#_encodeHeaders — Stomp::Connection
#_expand_hosts — Stomp::Connection
#_hdup — Stomp::Connection
#_headerCheck — Stomp::Connection
#_init — Slogger
#_init_heartbeats — Stomp::Connection
#_init_line_read — Stomp::Connection
#_is_ready? — Stomp::Connection
#_normalize_line_end — Stomp::Connection
#_post_connect — Stomp::Connection
#_pre_connect — Stomp::Connection
#_receive — Stomp::Connection
#_reconn_prep — Stomp::Connection
#_reconn_prep_hb — Stomp::Connection
#_start_receive_ticker — Stomp::Connection
#_start_send_ticker — Stomp::Connection
#_transmit — Stomp::Connection
#_valid_utf8? — Stomp::Connection
#_validate_hbheader — Stomp::Connection
#_wire_write — Stomp::Connection
#abort — Stomp::Client
#abort — Stomp::Connection
#ack — Stomp::Client
#ack — Stomp::Connection
#ack_context_for — Stomp::Client
#acknowledge — Stomp::Client
#autoflush — Stomp::Client
#autoflush= — Stomp::Client
#begin — Stomp::Connection
#begin — Stomp::Client
#caller_method_name — TestBase
#change_host — Stomp::Connection
#checkEmsg — TestBase
#check_arguments! — Stomp::Client
#client_ack? — Stomp::Connection
#close — Stomp::Client
#close_socket — Stomp::Connection
#closed? — Stomp::Connection
#closed? — Stomp::Client
#commit — Stomp::Client
#commit — Stomp::Connection
#conn_subscribe — TestBase
#connect — Stomp::Connection
#connection_frame — Stomp::Client
#create_connection — Stomp::Client
#create_error_handler — Stomp::Client
#create_listener_maps — Stomp::Client
#dflt_data_ex — TestBase
#dflt_data_ok — TestBase
#disconnect — Stomp::Connection
#disconnect_receipt — Stomp::Client
#empty? — Stomp::Message
#filter_options — Stomp::Client
#find_listener — Stomp::Client
#find_receipt_listener — Stomp::Client
#get_anonymous_connection — TestBase
#get_client — TestBase
#get_conn_headers — TestBase
#get_connection — Stomp11Common
#get_connection — TestBase
#get_crlf — TestBase
#get_ssl_connection — TestBase
#get_stomp_conn — TestBase
#hashed_initialize — Stomp::Connection
#hb_asserts_both — TestConnection1P
#hb_asserts_recv — TestConnection1P
#hb_asserts_send — TestConnection1P
#hbrecv_count — Stomp::Connection
#hbrecv_count — Stomp::Client
#hbrecv_interval — Stomp::Client
#hbrecv_interval — Stomp::Connection
#hbsend_count — Stomp::Client
#hbsend_count — Stomp::Connection
#hbsend_interval — Stomp::Client
#hbsend_interval — Stomp::Connection
#host — Stomp11Common
#host — TestBase
#increase_reconnect_delay — Stomp::Connection
#info — Tlogger
#info — Slogger
#is_blank? — Stomp::Message
#join — Stomp::Client
#jruby? — TestBase
#jruby? — Stomp::Client
#log_params — Stomp::Connection
#login — Stomp11Common
#make_destination — TestBase
#marshal_dump — Slogger
#marshal_load — Slogger
#max_reconnect_attempts? — Stomp::Connection
#message — Stomp::Error::PacketParsingTimeout
#message — Stomp::Error::SubscriptionRequiredError
#message — Stomp::Error::InvalidHeartBeatHeaderError
#message — Stomp::Error::UnsupportedProtocolError
#message — Stomp::Error::ProtocolErrorConnect
#message — Stomp::Error::ProtocolError11p
#message — Stomp::Error::ProtocolErrorEmptyHeaderValue
#message — Stomp::Error::ProtocolErrorEmptyHeaderKey
#message — Stomp::Error::DuplicateSubscription
#message — Stomp::Error::MaxReconnectAttempts
#message — Stomp::Error::NoCurrentConnection
#message — Stomp::Error::SocketOpenTimeout
#message — Stomp::Error::UTF8ValidationError
#message — Stomp::Error::InvalidMessageLength
#message — Stomp::Error::MessageIDRequiredError
#message — Stomp::Error::InvalidServerCommand
#message — Stomp::Error::SSLClientParamsError
#message — Stomp::Error::InvalidFormat
#message — Stomp::Error::StompServerError
#message — Stomp::Error::SSLNoKeyFileError
#message — Stomp::Error::SSLUnreadableKeyFileError
#message — Stomp::Error::SSLNoCertFileError
#message — Stomp::Error::SSLUnreadableCertFileError
#message — Stomp::Error::SSLNoTruststoreFileError
#message — Stomp::Error::SSLUnreadableTruststoreFileError
#message — Stomp::Error::MalformedFailoverOptionsError
#message — Stomp::Error::ConnectReadTimeout
#message — Stomp::Error::StartTimeoutException
#message — Stomp::Error::ReadReceiptTimeoutException
#message — Stomp::Error::NilMessageError
#message_text — TestClient
#nack — Stomp::Client
#nack — Stomp::Connection
#nmsgs — Stomp11Common
#on_abort — Stomp::NullLogger
#on_abort — Slogger
#on_ack — Stomp::NullLogger
#on_ack — Slogger
#on_begin — Slogger
#on_begin — Stomp::NullLogger
#on_commit — Slogger
#on_commit — Stomp::NullLogger
#on_connected — Slogger
#on_connected — Stomp::NullLogger
#on_connectfail — Stomp::NullLogger
#on_connectfail — Slogger
#on_connecting — Slogger
#on_connecting — Stomp::NullLogger
#on_disconnect — Stomp::NullLogger
#on_disconnect — Slogger
#on_hbfire — Tlogger
#on_hbfire — Stomp::NullLogger
#on_hbfire — Slogger
#on_hbread_fail — Tlogger
#on_hbread_fail — Stomp::NullLogger
#on_hbread_fail — Slogger
#on_hbwrite_fail — Tlogger
#on_hbwrite_fail — Stomp::NullLogger
#on_hbwrite_fail — Slogger
#on_miscerr — Stomp::NullLogger
#on_miscerr — Slogger
#on_miscerr — Tlogger
#on_nack — Stomp::NullLogger
#on_nack — Slogger
#on_publish — Stomp::NullLogger
#on_publish — Slogger
#on_receive — Stomp::NullLogger
#on_receive — Slogger
#on_ssl_connected — Slogger
#on_ssl_connected — Stomp::NullLogger
#on_ssl_connectfail — Slogger
#on_ssl_connectfail — Stomp::NullLogger
#on_ssl_connecting — Stomp::NullLogger
#on_ssl_connecting — Slogger
#on_subscribe — Stomp::NullLogger
#on_subscribe — Slogger
#on_unsubscribe — Slogger
#on_unsubscribe — Stomp::NullLogger
#open? — Stomp::Client
#open? — Stomp::Connection
#open_socket — Stomp::Connection
#open_ssl_socket — Stomp::Connection
#open_tcp_socket — Stomp::Connection
#parse_caller — TestBase
#parse_char — Stomp::Connection
#parse_failover_url — Stomp::Client
#parse_hash_params — Stomp::Client
#parse_hosts — Stomp::Client
#parse_positional_params — Stomp::Client
#parse_stomp_url — Stomp::Client
#passcode — Stomp11Common
#passcode — TestBase
#poll — Stomp::Client
#poll — Stomp::Connection
#port — Stomp11Common
#port — TestBase
#protocol — Stomp::Client
#publish — Stomp::Client
#publish — Stomp::Connection
#receive — Stomp::Connection
#refine_params — Stomp::Connection
#register_receipt_listener — Stomp::Client
#run — RepeatedHeadersExample
#run — Receive11Example1
#run — Client11PutGet1
#run — ExampleSSLNewParm
#run — ExampleConsumer
#run — Connection11Example2
#run — Connection11Example1
#run — ExampleSSL1
#run — ExampleSSL1C
#run — Receive11Example2
#run — ExampleSSL2
#run — ExampleSSL2C
#run — LoggerExample
#run — SSLLoggerExample
#run — ExamplePublisher
#run — ExampleTopicPublisher
#run — HeartBeatExample1
#run — Client11Example1
#run — Publish11Example1
#run — ExampleTopicConsumer
#run — ExampleRubyCiphers
#run — ExampleSSL4C
#run — ExampleSSL3C
#run — ExampleSSL3
#run — ExampleSSL4
#run1 — ExampleSSLCtxOptions
#run2 — ExampleSSLCtxOptions
#running — Stomp::Client
#set_logger — Stomp::Client
#set_logger — Stomp::Connection
#set_subscription_id_if_missing — Stomp::Client
#setup — TestConnection1P
#setup — TestCodec
#setup — TestAnonymous
#setup — TestClient
#setup — TestSSL
#setup — TestMessage
#setup — TestConnection
#setup — TestURLLogins
#sha1 — Stomp::Client
#sha1 — Stomp::Connection
#slog — Stomp::Connection
#socket — Stomp::Connection
#ssl_port — TestBase
#start_listeners — Stomp::Client
#subscribe — Stomp::Client
#subscribe — Stomp::Connection
#symbolize_keys — Hash
#teardown — TestConnection1P
#teardown — TestClient
#teardown — TestConnection
#teardown — TestCodec
#teardown — TestMessage
#teardown — TestAnonymous
#teardown — TestSSL
#teardown — TestURLLogins
#test_0010_kcode — TestMessage
#test_0010_stomp_urls — TestURLLogins
#test_0020_failover_badparms — TestURLLogins
#test_0020_failover_urls — TestURLLogins
#test_0020_kcode — TestMessage
#test_0030_kcode — TestMessage
#test_0040_msg_create — TestMessage
#test_0050_mh_msg_create — TestMessage
#test_0060_hdr_ekv — TestMessage
#test_1000_check_notneeded — TestCodec
#test_1010_basic_encode_decode — TestCodec
#test_1020_fancier — TestCodec
#test_ack_api_works — TestClient
#test_asterisk_wildcard_subscribe — TestClient
#test_asynch_subscribe — TestClient
#test_cli_iss99_ex — TestClient
#test_cli_iss99_ok — TestClient
#test_client_ack_with_symbol_10 — TestConnection
#test_client_ack_with_symbol_10 — TestAnonymous
#test_client_ack_with_symbol_11 — TestAnonymous
#test_client_ack_with_symbol_11 — TestConnection
#test_client_ack_with_symbol_12 — TestConnection
#test_client_ack_with_symbol_12 — TestAnonymous
#test_closed_checks_client — TestClient
#test_closed_checks_conn — TestAnonymous
#test_closed_checks_conn — TestConnection
#test_con_iss99_ok — TestConnection
#test_conn10_simple — TestConnection
#test_conn10_simple — TestAnonymous
#test_conn_11h_0060 — TestConnection1P
#test_conn_1p_0000 — TestConnection1P
#test_conn_1p_0010 — TestConnection1P
#test_conn_1p_0015 — TestConnection1P
#test_conn_1p_0020 — TestConnection1P
#test_conn_1p_0030 — TestConnection1P
#test_conn_1p_0040 — TestConnection1P
#test_conn_1p_0050 — TestConnection1P
#test_conn_1p_0070 — TestConnection1P
#test_conn_1p_0080 — TestConnection1P
#test_conn_1p_0090 — TestConnection1P
#test_conn_1p_0100 — TestConnection1P
#test_conn_1p_0110 — TestConnection1P
#test_conn_1p_0120 — TestConnection1P
#test_conn_1p_0124 — TestConnection1P
#test_conn_1p_0127 — TestConnection1P
#test_conn_1p_0130 — TestConnection1P
#test_conn_1p_0135 — TestConnection1P
#test_conn_1p_0140 — TestConnection1P
#test_conn_1p_0200 — TestConnection1P
#test_conn_1p_0210 — TestConnection1P
#test_connection_closed? — TestAnonymous
#test_connection_closed? — TestConnection
#test_connection_exists — TestConnection
#test_connection_exists — TestAnonymous
#test_connection_frame — TestClient
#test_connection_frame — TestConnection
#test_connection_frame — TestAnonymous
#test_connection_open? — TestConnection
#test_connection_open? — TestAnonymous
#test_disconnect_receipt — TestClient
#test_disconnect_receipt — TestConnection
#test_disconnect_receipt — TestAnonymous
#test_duplicate_subscription — TestConnection
#test_duplicate_subscription — TestAnonymous
#test_embedded_null — TestConnection
#test_embedded_null — TestAnonymous
#test_empty_header_key — TestConnection
#test_empty_header_value — TestConnection
#test_explicit_receive — TestConnection
#test_explicit_receive — TestAnonymous
#test_greater_than_wildcard_subscribe — TestClient
#test_jruby_presence — TestAnonymous
#test_jruby_presence — TestConnection
#test_jruby_presence — TestClient
#test_max_redeliveries — TestClient
#test_message_to_s — TestAnonymous
#test_message_to_s — TestConnection
#test_messages_with_multipleLine_ends — TestAnonymous
#test_messages_with_multipleLine_ends — TestConnection
#test_multi_thread_poll — TestAnonymous
#test_multi_thread_poll — TestConnection
#test_multi_thread_receive — TestConnection
#test_multi_thread_receive — TestAnonymous
#test_nack11p_0010 — TestConnection
#test_nack11p_0010 — TestAnonymous
#test_nil_body — TestAnonymous
#test_nil_body — TestConnection
#test_nil_connparms — TestConnection
#test_nil_connparms — TestAnonymous
#test_no_length — TestConnection
#test_no_length — TestAnonymous
#test_noack — TestClient
#test_poll_async — TestAnonymous
#test_poll_async — TestClient
#test_poll_async — TestConnection
#test_publish_then_sub — TestClient
#test_publish_two_messages — TestConnection
#test_publish_two_messages — TestAnonymous
#test_raise_on_multiple_subscriptions_to_same_id — TestClient
#test_raise_on_multiple_subscriptions_to_same_id_mixed — TestClient
#test_raise_on_multiple_subscriptions_to_same_make_destination — TestClient
#test_receipt — TestConnection
#test_receipt — TestAnonymous
#test_receipts — TestClient
#test_response_is_instance_of_message_class — TestConnection
#test_response_is_instance_of_message_class — TestAnonymous
#test_ssl_0000 — TestSSL
#test_ssl_0010_parms — TestSSL
#test_ssl_0020_noraise — TestSSL
#test_ssl_0030_raise — TestSSL
#test_ssl_0040_fsck — TestSSL
#test_subscribe_requires_block — TestClient
#test_thread_hang_one — TestConnection
#test_thread_hang_one — TestAnonymous
#test_thread_multi_subscribe — TestClient
#test_thread_one_subscribe — TestClient
#test_thread_poll_one — TestAnonymous
#test_thread_poll_one — TestConnection
#test_tran_ack_abrt_newcli_auto — TestClient
#test_tran_ack_abrt_newcli_cli — TestClient
#test_transaction — TestConnection
#test_transaction — TestAnonymous
#test_transaction_publish_then_rollback — TestClient
#test_transaction_with_client_side_reack — TestClient
#test_transactional_publish — TestClient
#test_unsubscribe — TestClient
#to_s — Stomp::Message
#transmit — Stomp::Connection
#uncamelize_and_stringify_keys — Hash
#uncamelize_and_symbolize_keys — Hash
#unreceive — Stomp::Connection
#unreceive — Stomp::Client
#unsubscribe — Stomp::Client
#unsubscribe — Stomp::Connection
#user — TestBase
#uuid — Stomp::Connection
#uuid — Stomp::Client
#valid_utf8? — Stomp::Client
#valid_utf8? — Stomp::Connection
#virt_host — Stomp11Common