Module: OnStomp::Connections

Defined in:

lib/onstomp/connections.rb,
lib/onstomp/connections.rb

Overview

Defined Under Namespace

Modules: Heartbeating, Serializers, Stomp_1 Classes: Base, Stomp_1_0, Stomp_1_1

Constant Summary

DEFAULT_SSL_OPTIONS =

Default SSL options to use when establishing an SSL connection.

{
  :verify_mode => OpenSSL::SSL::VERIFY_PEER |
    OpenSSL::SSL::VERIFY_FAIL_IF_NO_PEER_CERT,
  :ca_file => nil,
  :ca_path => nil,
  :cert => nil,
  :key => nil,
  :post_connection_check => true
}

PROTOCOL_VERSIONS =

A mapping of protocol versions to the connection classes that support them.

{
  '1.0' => OnStomp::Connections::Stomp_1_0,
  '1.1' => OnStomp::Connections::Stomp_1_1
}

Class Method Summary (collapse)

• + (OnStomp::Connections::Base) connect(client, u_head, c_head, con_cbs, r_time, w_time)

  Creates an initial connection to the client's broker uri, performs the CONNECT/CONNECTED frame exchange, and returns a connection suitable for the negotiated STOMP protocol version.

• + (Array<String>) select_supported(vers)

  Filters a list of supplied versions to only those that are supported.

• + (Array<String>) supported

  Returns a list of supported protocol versions.

47
48
49
50
51
52
53
54
55
56
57
58
59

# File 'lib/onstomp/connections.rb', line 47

def self.connect client, u_head, c_head, con_cbs, r_time, w_time
  init_con = create_connection('1.0', nil, client, r_time, w_time)
  ver, connected = init_con.connect client, u_head, c_head
  begin
    negotiate_connection(ver, init_con, client).tap do |final_con|
      final_con.configure connected, con_cbs
    end
  rescue OnStomp::OnStompError
    # Perform a blocking close.
    init_con.close true
    raise
  end
end

29
30
31
32

# File 'lib/onstomp/connections.rb', line 29

def self.select_supported vers
  vers = Array(vers)
  supported.select { |v| vers.include? v }
end

19
20
21

# File 'lib/onstomp/connections.rb', line 19

def self.supported
  PROTOCOL_VERSIONS.keys.sort
end