activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [3/4] activemq-artemis git commit: ARTEMIS-227 allow adding STOMP interceptor instances
Date Fri, 25 Sep 2015 22:10:05 GMT
ARTEMIS-227 allow adding STOMP interceptor instances


Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/fe16ffe0
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/fe16ffe0
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/fe16ffe0

Branch: refs/heads/master
Commit: fe16ffe0682e94a60cf665df685930ce6ecd815d
Parents: 616f683
Author: Julian Scheid <julians37@gmail.com>
Authored: Fri Sep 25 14:09:28 2015 +0200
Committer: Clebert Suconic <clebertsuconic@apache.org>
Committed: Fri Sep 25 14:56:26 2015 -0400

----------------------------------------------------------------------
 .../artemis/core/remoting/server/RemotingService.java       | 9 ++++-----
 .../core/remoting/server/impl/RemotingServiceImpl.java      | 9 ++++-----
 .../activemq/artemis/core/server/ServiceRegistry.java       | 5 ++---
 .../artemis/core/server/impl/ServiceRegistryImpl.java       | 5 ++---
 4 files changed, 12 insertions(+), 16 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/fe16ffe0/artemis-server/src/main/java/org/apache/activemq/artemis/core/remoting/server/RemotingService.java
----------------------------------------------------------------------
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/remoting/server/RemotingService.java
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/remoting/server/RemotingService.java
index e940c02..6079be4 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/remoting/server/RemotingService.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/remoting/server/RemotingService.java
@@ -20,7 +20,6 @@ import java.util.List;
 import java.util.Set;
 
 import org.apache.activemq.artemis.api.core.BaseInterceptor;
-import org.apache.activemq.artemis.api.core.Interceptor;
 import org.apache.activemq.artemis.core.protocol.core.CoreRemotingConnection;
 import org.apache.activemq.artemis.core.security.ActiveMQPrincipal;
 import org.apache.activemq.artemis.spi.core.protocol.RemotingConnection;
@@ -43,17 +42,17 @@ public interface RemotingService {
 
    ReusableLatch getConnectionCountLatch();
 
-   void addIncomingInterceptor(Interceptor interceptor);
+   void addIncomingInterceptor(BaseInterceptor interceptor);
 
    List<BaseInterceptor> getIncomingInterceptors();
 
-   void addOutgoingInterceptor(Interceptor interceptor);
+   void addOutgoingInterceptor(BaseInterceptor interceptor);
 
    List<BaseInterceptor> getOutgoinInterceptors();
 
-   boolean removeIncomingInterceptor(Interceptor interceptor);
+   boolean removeIncomingInterceptor(BaseInterceptor interceptor);
 
-   boolean removeOutgoingInterceptor(Interceptor interceptor);
+   boolean removeOutgoingInterceptor(BaseInterceptor interceptor);
 
    void stop(boolean criticalError) throws Exception;
 

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/fe16ffe0/artemis-server/src/main/java/org/apache/activemq/artemis/core/remoting/server/impl/RemotingServiceImpl.java
----------------------------------------------------------------------
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/remoting/server/impl/RemotingServiceImpl.java
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/remoting/server/impl/RemotingServiceImpl.java
index 5b273c3..ab9de61 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/remoting/server/impl/RemotingServiceImpl.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/remoting/server/impl/RemotingServiceImpl.java
@@ -40,7 +40,6 @@ import org.apache.activemq.artemis.api.core.ActiveMQBuffer;
 import org.apache.activemq.artemis.api.core.ActiveMQException;
 import org.apache.activemq.artemis.api.core.ActiveMQInterruptedException;
 import org.apache.activemq.artemis.api.core.BaseInterceptor;
-import org.apache.activemq.artemis.api.core.Interceptor;
 import org.apache.activemq.artemis.api.core.TransportConfiguration;
 import org.apache.activemq.artemis.core.config.Configuration;
 import org.apache.activemq.artemis.core.protocol.core.CoreRemotingConnection;
@@ -525,7 +524,7 @@ public class RemotingServiceImpl implements RemotingService, ConnectionLifeCycle
    }
 
    @Override
-   public void addIncomingInterceptor(final Interceptor interceptor) {
+   public void addIncomingInterceptor(final BaseInterceptor interceptor) {
       incomingInterceptors.add(interceptor);
 
       updateProtocols();
@@ -537,7 +536,7 @@ public class RemotingServiceImpl implements RemotingService, ConnectionLifeCycle
    }
 
    @Override
-   public boolean removeIncomingInterceptor(final Interceptor interceptor) {
+   public boolean removeIncomingInterceptor(final BaseInterceptor interceptor) {
       if (incomingInterceptors.remove(interceptor)) {
          updateProtocols();
          return true;
@@ -548,7 +547,7 @@ public class RemotingServiceImpl implements RemotingService, ConnectionLifeCycle
    }
 
    @Override
-   public void addOutgoingInterceptor(final Interceptor interceptor) {
+   public void addOutgoingInterceptor(final BaseInterceptor interceptor) {
       outgoingInterceptors.add(interceptor);
       updateProtocols();
    }
@@ -559,7 +558,7 @@ public class RemotingServiceImpl implements RemotingService, ConnectionLifeCycle
    }
 
    @Override
-   public boolean removeOutgoingInterceptor(final Interceptor interceptor) {
+   public boolean removeOutgoingInterceptor(final BaseInterceptor interceptor) {
       if (outgoingInterceptors.remove(interceptor)) {
          updateProtocols();
          return true;

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/fe16ffe0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/ServiceRegistry.java
----------------------------------------------------------------------
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/ServiceRegistry.java
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/ServiceRegistry.java
index 9cb1df1..dfa86b7 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/ServiceRegistry.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/ServiceRegistry.java
@@ -17,7 +17,6 @@
 package org.apache.activemq.artemis.core.server;
 
 import org.apache.activemq.artemis.api.core.BaseInterceptor;
-import org.apache.activemq.artemis.api.core.Interceptor;
 import org.apache.activemq.artemis.api.core.Pair;
 import org.apache.activemq.artemis.core.config.ConnectorServiceConfiguration;
 import org.apache.activemq.artemis.core.server.cluster.Transformer;
@@ -55,7 +54,7 @@ public interface ServiceRegistry {
     */
    Collection<Pair<ConnectorServiceFactory, ConnectorServiceConfiguration>> getConnectorServices(List<ConnectorServiceConfiguration>
configs);
 
-   void addIncomingInterceptor(Interceptor interceptor);
+   void addIncomingInterceptor(BaseInterceptor interceptor);
 
    /**
     * Get a list of org.apache.activemq.artemis.api.core.BaseInterceptor instances
@@ -65,7 +64,7 @@ public interface ServiceRegistry {
     */
    List<BaseInterceptor> getIncomingInterceptors(List<String> classNames);
 
-   void addOutgoingInterceptor(Interceptor interceptor);
+   void addOutgoingInterceptor(BaseInterceptor interceptor);
 
    /**
     * Get a list of org.apache.activemq.artemis.api.core.BaseInterceptor instances

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/fe16ffe0/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServiceRegistryImpl.java
----------------------------------------------------------------------
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServiceRegistryImpl.java
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServiceRegistryImpl.java
index 715d92f..d00e15e 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServiceRegistryImpl.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServiceRegistryImpl.java
@@ -17,7 +17,6 @@
 package org.apache.activemq.artemis.core.server.impl;
 
 import org.apache.activemq.artemis.api.core.BaseInterceptor;
-import org.apache.activemq.artemis.api.core.Interceptor;
 import org.apache.activemq.artemis.api.core.Pair;
 import org.apache.activemq.artemis.core.config.ConnectorServiceConfiguration;
 import org.apache.activemq.artemis.core.server.ActiveMQMessageBundle;
@@ -118,7 +117,7 @@ public class ServiceRegistryImpl implements ServiceRegistry {
    }
 
    @Override
-   public void addIncomingInterceptor(Interceptor interceptor) {
+   public void addIncomingInterceptor(BaseInterceptor interceptor) {
       incomingInterceptors.add(interceptor);
    }
 
@@ -132,7 +131,7 @@ public class ServiceRegistryImpl implements ServiceRegistry {
    }
 
    @Override
-   public void addOutgoingInterceptor(Interceptor interceptor) {
+   public void addOutgoingInterceptor(BaseInterceptor interceptor) {
       outgoingInterceptors.add(interceptor);
    }
 


Mime
View raw message