activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r490789 - /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java
Date Thu, 28 Dec 2006 20:44:59 GMT
Author: rajdavies
Date: Thu Dec 28 12:44:59 2006
New Revision: 490789

URL: http://svn.apache.org/viewvc?view=rev&rev=490789
Log:
drop synchronization from connectionState and connection context - 
not required when using ConcurrentHashMap and limited concurrency for 
publishers or transactions for the same client connection 

Modified:
    incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java?view=diff&rev=490789&r1=490788&r2=490789
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java
(original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java
Thu Dec 28 12:44:59 2006
@@ -352,7 +352,7 @@
         return null;
     }
 
-    synchronized public Response processBeginTransaction(TransactionInfo info) throws Exception
{
+    public Response processBeginTransaction(TransactionInfo info) throws Exception {
         ConnectionState cs = (ConnectionState) localConnectionStates.get(info.getConnectionId());
         ConnectionContext context=null;
         if( cs!=null ) {
@@ -367,14 +367,14 @@
         return null;
     }
     
-    synchronized public Response processEndTransaction(TransactionInfo info) throws Exception
{
+    public Response processEndTransaction(TransactionInfo info) throws Exception {
         // No need to do anything.  This packet is just sent by the client
         // make sure he is synced with the server as commit command could
         // come from a different connection.
         return null;
     }
     
-    synchronized public Response processPrepareTransaction(TransactionInfo info) throws Exception
{
+    public Response processPrepareTransaction(TransactionInfo info) throws Exception {
         ConnectionState cs = (ConnectionState) localConnectionStates.get(info.getConnectionId());
         ConnectionContext context=null;
         if( cs!=null ) {
@@ -398,7 +398,7 @@
         }
     }
 
-    synchronized public Response processCommitTransactionOnePhase(TransactionInfo info) throws
Exception {
+    public Response processCommitTransactionOnePhase(TransactionInfo info) throws Exception
{
         ConnectionState cs = (ConnectionState) localConnectionStates.get(info.getConnectionId());
         ConnectionContext context=null;
         if( cs!=null ) {
@@ -412,7 +412,7 @@
         
     }
 
-    synchronized public Response processCommitTransactionTwoPhase(TransactionInfo info) throws
Exception {
+    public Response processCommitTransactionTwoPhase(TransactionInfo info) throws Exception
{
         ConnectionState cs = (ConnectionState) localConnectionStates.get(info.getConnectionId());
         ConnectionContext context=null;
         if( cs!=null ) {
@@ -424,7 +424,7 @@
         return null;
     }
 
-    synchronized public Response processRollbackTransaction(TransactionInfo info) throws
Exception {
+    public Response processRollbackTransaction(TransactionInfo info) throws Exception {
         ConnectionState cs = (ConnectionState) localConnectionStates.get(info.getConnectionId());
         ConnectionContext context=null;
         if( cs!=null ) {
@@ -436,7 +436,7 @@
         return null;
     }
     
-    synchronized public Response processForgetTransaction(TransactionInfo info) throws Exception
{
+    public Response processForgetTransaction(TransactionInfo info) throws Exception {
         ConnectionState cs = (ConnectionState) localConnectionStates.get(info.getConnectionId());
         ConnectionContext context=null;
         if( cs!=null ) {
@@ -446,7 +446,7 @@
         return null;
     }
     
-    synchronized public Response processRecoverTransactions(TransactionInfo info) throws
Exception {
+    public Response processRecoverTransactions(TransactionInfo info) throws Exception {
         ConnectionState cs = (ConnectionState) localConnectionStates.get(info.getConnectionId());
         ConnectionContext context=null;
         if( cs!=null ) {
@@ -501,7 +501,7 @@
         return null;
     }
 
-    synchronized public Response processAddDestination(DestinationInfo info) throws Exception
{
+    public Response processAddDestination(DestinationInfo info) throws Exception {
         ConnectionState cs = lookupConnectionState(info.getConnectionId());
         broker.addDestinationInfo(cs.getContext(), info);
         if( info.getDestination().isTemporary() ) {
@@ -510,7 +510,7 @@
         return null;
     }
 
-    synchronized public Response processRemoveDestination(DestinationInfo info) throws Exception
{
+    public Response processRemoveDestination(DestinationInfo info) throws Exception {
         ConnectionState cs = lookupConnectionState(info.getConnectionId());
         broker.removeDestinationInfo(cs.getContext(), info);
         if( info.getDestination().isTemporary() ) {
@@ -520,7 +520,7 @@
     }
 
 
-    synchronized public Response processAddProducer(ProducerInfo info) throws Exception {
+    public Response processAddProducer(ProducerInfo info) throws Exception {
         SessionId sessionId = info.getProducerId().getParentId();
         ConnectionId connectionId = sessionId.getParentId();
         
@@ -541,7 +541,7 @@
         return null;
     }
     
-    synchronized public Response processRemoveProducer(ProducerId id) throws Exception {
+    public Response processRemoveProducer(ProducerId id) throws Exception {
         SessionId sessionId = id.getParentId();
         ConnectionId connectionId = sessionId.getParentId();
         
@@ -557,7 +557,7 @@
         return null;
     }
 
-    synchronized public Response processAddConsumer(ConsumerInfo info) throws Exception {
+    public Response processAddConsumer(ConsumerInfo info) throws Exception {
         SessionId sessionId = info.getConsumerId().getParentId();
         ConnectionId connectionId = sessionId.getParentId();
         
@@ -579,7 +579,7 @@
         return null;
     }
     
-    synchronized public Response processRemoveConsumer(ConsumerId id) throws Exception {
+    public Response processRemoveConsumer(ConsumerId id) throws Exception {
         
         SessionId sessionId = id.getParentId();
         ConnectionId connectionId = sessionId.getParentId();
@@ -596,7 +596,7 @@
         return null;
     }
     
-    synchronized public Response processAddSession(SessionInfo info) throws Exception {
+    public Response processAddSession(SessionInfo info) throws Exception {
         ConnectionId connectionId = info.getSessionId().getParentId();
         ConnectionState cs = lookupConnectionState(connectionId);
         
@@ -612,7 +612,7 @@
         return null;
     }
     
-    synchronized public Response processRemoveSession(SessionId id) throws Exception {
+    public Response processRemoveSession(SessionId id) throws Exception {
         
         ConnectionId connectionId = id.getParentId();
         
@@ -649,7 +649,7 @@
         return null;
     }
     
-    synchronized public Response processAddConnection(ConnectionInfo info) throws Exception
{
+    public Response processAddConnection(ConnectionInfo info) throws Exception {
 
     	ConnectionState state = (ConnectionState) brokerConnectionStates.get(info.getConnectionId());
     	
@@ -698,7 +698,7 @@
         return null;
     }
     
-    synchronized public Response processRemoveConnection(ConnectionId id)  {
+    public Response processRemoveConnection(ConnectionId id)  {
         
         ConnectionState cs = lookupConnectionState(id);
         



Mime
View raw message