You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2013/07/31 17:31:07 UTC
svn commit: r1508926 -
/activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Broker.scala
Author: chirino
Date: Wed Jul 31 15:31:06 2013
New Revision: 1508926
URL: http://svn.apache.org/r1508926
Log:
Adding a method to broker to get the socket address for a specific connector id.
Modified:
activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Broker.scala
Modified: activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Broker.scala
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Broker.scala?rev=1508926&r1=1508925&r2=1508926&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Broker.scala (original)
+++ activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Broker.scala Wed Jul 31 15:31:06 2013
@@ -719,12 +719,17 @@ class Broker() extends BaseService with
}
}
- def get_socket_address = {
- first_accepting_connector.get.socket_address
- }
-
+ def get_socket_address = first_accepting_connector.get.socket_address
def first_accepting_connector = connectors.values.find(_.isInstanceOf[AcceptingConnector]).map(_.asInstanceOf[AcceptingConnector])
+ def get_socket_address(id:String) = accepting_connector(id).get.socket_address
+ def accepting_connector(id:String) = {
+ connectors.values.find( _ match {
+ case connector:AcceptingConnector => connector.id == id
+ case _ => false
+ }).map(_.asInstanceOf[AcceptingConnector])
+ }
+
def ssl_context(protocol:String) = {
val rc = SSLContext.getInstance(protocol);
if( key_storage!=null ) {