0 Replies Latest reply on Aug 8, 2014 5:33 AM by cgraf1

CommunicationException in remote JMS Client when destination queue in DMZ

cgraf1 Aug 8, 2014 5:33 AM

I have the following setup:

One Wildfly 8.1 (W1) runs in an internal network. A second Wildlfy (W2) runs in a Demilitarized Zone (DMZ). That means outgoing connections from W2 to W1 are denied.

On W2 a queue named "myqueue" is defined in standalone-full.xml:

<jms-queue name="myqueue">

</jms-queue>

On W1 runs a Web application (WAR) with a JMS remote client, that receives messages synchronously:

@Path("test/qreceiver")

@Stateless

public class AntwortQueueReceiver {

private static final String INITIAL_CONTEXT_FACTORY = "org.jboss.naming.remote.client.InitialContextFactory";

private static final String PROVIDER_URL = "http-remoting://10.0.9.215:8080";

private static final String USERNAME = "jmsuser";

private static final String PASSWORD = "geheim";

// see <connection-factory name="RemoteConnectionFactory">

private static final String CONNECTION_FACTORY = "jms/RemoteConnectionFactory";

private static final String DESTINATION = "jms/queue/myqueue";

@Inject

Logger log;

@GET

@Produces(MediaType.TEXT_PLAIN)

public Response receive() {

log.log(Level.FINE, "receive()");

// Set up the context for the JNDI lookup

final Properties env = new Properties();

String body = null;

try {

env.put(Context.INITIAL_CONTEXT_FACTORY, INITIAL_CONTEXT_FACTORY);

env.put(Context.PROVIDER_URL, PROVIDER_URL);

env.put(Context.SECURITY_PRINCIPAL, USERNAME);

env.put(Context.SECURITY_CREDENTIALS, PASSWORD);

Context context = new InitialContext(env);

// Perform the JNDI lookups

log.info("Attempting to acquire connection factory \"" + CONNECTION_FACTORY + "\"");

// here java.net.ConnectException is thrown, when traffic W2 => W1 is denied

ConnectionFactory connectionFactory = (ConnectionFactory) context.lookup(CONNECTION_FACTORY);

log.info("Found connection factory \"" + CONNECTION_FACTORY + "\" in JNDI");

log.info("Attempting to acquire destination \"" + DESTINATION + "\"");

Destination destination = (Destination) context.lookup(DESTINATION);

log.info("Found destination \"" + DESTINATION + "\" in JNDI");

JMSContext jmsContext = connectionFactory.createContext(USERNAME, PASSWORD, JMSContext.SESSION_TRANSACTED);

JMSConsumer consumer = jmsContext.createConsumer(destination);

Message message = consumer.receiveNoWait();

try {

if (message != null) {

body = message.getBody(String.class);

log.log(Level.FINE, "message received: {0}", body);

jmsContext.commit();

}

} catch (JMSException e) {

e.printStackTrace();

} finally {

jmsContext.close();

}

} catch (NamingException e) {

e.printStackTrace();

}

return Response.ok().build();

}

Now everything works fine, until I deny outgoing network traffic from W2 to W1. A javax.naming.CommunicationException (caused by java.net.ConnectException) is thrown when the following code is executed:

ConnectionFactory connectionFactory = (ConnectionFactory) context.lookup(connectionFactoryString);

I don't understand why the lookup from the client side (W1) depends on outgoing connections from the server side (W2 => W1), where the destination queue is defined.

Is there way to overcome the problem? It is not an option to allow for outgoing traffic from W2 to W1.

Here the stack trace:

11:13:40,961 INFO [de.test.web.business.antwort.boundary.AntwortQueueReceiver] (default task-1) Attempting to acquire connection factory "jms/RemoteConnectionFactory"

11:13:50,480 ERROR [stderr] (default task-1) javax.naming.CommunicationException: Failed to connect to any server. Servers tried: [http-remoting://10.0.9.215:8080 (Operation failed with status WAITING after 5000 MILLISECONDS)] [Root exception is java.net.ConnectException: Operation failed with status WAITING after 5000 MILLISECONDS]

11:13:50,480 ERROR [stderr] (default task-1) at org.jboss.naming.remote.client.HaRemoteNamingStore.failOverSequence(HaRemoteNamingStore.java:240)

11:13:50,480 ERROR [stderr] (default task-1) at org.jboss.naming.remote.client.HaRemoteNamingStore.namingStore(HaRemoteNamingStore.java:149)

11:13:50,480 ERROR [stderr] (default task-1) at org.jboss.naming.remote.client.HaRemoteNamingStore.namingOperation(HaRemoteNamingStore.java:130)

11:13:50,480 ERROR [stderr] (default task-1) at org.jboss.naming.remote.client.HaRemoteNamingStore.lookup(HaRemoteNamingStore.java:272)

11:13:50,480 ERROR [stderr] (default task-1) at org.jboss.naming.remote.client.RemoteContext.lookup(RemoteContext.java:87)

11:13:50,481 ERROR [stderr] (default task-1) at org.jboss.naming.remote.client.RemoteContext.lookup(RemoteContext.java:129)

11:13:50,481 ERROR [stderr] (default task-1) at javax.naming.InitialContext.lookup(InitialContext.java:417)

11:13:50,481 ERROR [stderr] (default task-1) at de.test.web.business.antwort.boundary.AntwortQueueReceiver.receive(AntwortQueueReceiver.java:63)

11:13:50,481 ERROR [stderr] (default task-1) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)

11:13:50,481 ERROR [stderr] (default task-1) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)

11:13:50,481 ERROR [stderr] (default task-1) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)

11:13:50,481 ERROR [stderr] (default task-1) at java.lang.reflect.Method.invoke(Method.java:483)

11:13:50,481 ERROR [stderr] (default task-1) at org.jboss.as.ee.component.ManagedReferenceMethodInterceptor.processInvocation(ManagedReferenceMethodInterceptor.java:52)

11:13:50,481 ERROR [stderr] (default task-1) at org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:309)

11:13:50,482 ERROR [stderr] (default task-1) at org.jboss.invocation.WeavedInterceptor.processInvocation(WeavedInterceptor.java:53)

11:13:50,482 ERROR [stderr] (default task-1) at org.jboss.as.ee.component.interceptors.UserInterceptorFactory$1.processInvocation(UserInterceptorFactory.java:63)

11:13:50,482 ERROR [stderr] (default task-1) at org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:309)

11:13:50,482 ERROR [stderr] (default task-1) at org.jboss.invocation.InterceptorContext$Invocation.proceed(InterceptorContext.java:407)

11:13:50,482 ERROR [stderr] (default task-1) at org.jboss.as.weld.ejb.Jsr299BindingsInterceptor.doMethodInterception(Jsr299BindingsInterceptor.java:82)

11:13:50,482 ERROR [stderr] (default task-1) at org.jboss.as.weld.ejb.Jsr299BindingsInterceptor.processInvocation(Jsr299BindingsInterceptor.java:93)

11:13:50,482 ERROR [stderr] (default task-1) at org.jboss.as.ee.component.interceptors.UserInterceptorFactory$1.processInvocation(UserInterceptorFactory.java:63)

11:13:50,482 ERROR [stderr] (default task-1) at org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:309)

11:13:50,482 ERROR [stderr] (default task-1) at org.jboss.invocation.WeavedInterceptor.processInvocation(WeavedInterceptor.java:53)

11:13:50,482 ERROR [stderr] (default task-1) at org.jboss.as.ee.component.interceptors.UserInterceptorFactory$1.processInvocation(UserInterceptorFactory.java:63)

11:13:50,482 ERROR [stderr] (default task-1) at org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:309)

11:13:50,483 ERROR [stderr] (default task-1) at org.jboss.as.ejb3.component.invocationmetrics.ExecutionTimeInterceptor.processInvocation(ExecutionTimeInterceptor.java:43)

11:13:50,483 ERROR [stderr] (default task-1) at org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:309)

11:13:50,483 ERROR [stderr] (default task-1) at org.jboss.as.jpa.interceptor.SBInvocationInterceptor.processInvocation(SBInvocationInterceptor.java:47)

11:13:50,483 ERROR [stderr] (default task-1) at org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:309)

11:13:50,483 ERROR [stderr] (default task-1) at org.jboss.invocation.InterceptorContext$Invocation.proceed(InterceptorContext.java:407)

11:13:50,483 ERROR [stderr] (default task-1) at org.jboss.weld.ejb.AbstractEJBRequestScopeActivationInterceptor.aroundInvoke(AbstractEJBRequestScopeActivationInterceptor.java:46)

11:13:50,483 ERROR [stderr] (default task-1) at org.jboss.as.weld.ejb.EjbRequestScopeActivationInterceptor.processInvocation(EjbRequestScopeActivationInterceptor.java:83)

11:13:50,483 ERROR [stderr] (default task-1) at org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:309)

11:13:50,483 ERROR [stderr] (default task-1) at org.jboss.as.ee.concurrent.ConcurrentContextInterceptor.processInvocation(ConcurrentContextInterceptor.java:45)

11:13:50,483 ERROR [stderr] (default task-1) at org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:309)

11:13:50,483 ERROR [stderr] (default task-1) at org.jboss.invocation.InitialInterceptor.processInvocation(InitialInterceptor.java:21)

11:13:50,484 ERROR [stderr] (default task-1) at org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:309)

11:13:50,484 ERROR [stderr] (default task-1) at org.jboss.invocation.ChainedInterceptor.processInvocation(ChainedInterceptor.java:61)

11:13:50,484 ERROR [stderr] (default task-1) at org.jboss.as.ee.component.interceptors.ComponentDispatcherInterceptor.processInvocation(ComponentDispatcherInterceptor.java:53)

11:13:50,484 ERROR [stderr] (default task-1) at org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:309)

11:13:50,484 ERROR [stderr] (default task-1) at org.jboss.as.ejb3.component.interceptors.NonPooledEJBComponentInstanceAssociatingInterceptor.processInvocation(NonPooledEJBComponentInstanceAssociatingInterceptor.java:59)

11:13:50,484 ERROR [stderr] (default task-1) at org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:309)

11:13:50,484 ERROR [stderr] (default task-1) at org.jboss.as.ejb3.tx.CMTTxInterceptor.invokeInOurTx(CMTTxInterceptor.java:273)

11:13:50,484 ERROR [stderr] (default task-1) at org.jboss.as.ejb3.tx.CMTTxInterceptor.required(CMTTxInterceptor.java:340)

11:13:50,484 ERROR [stderr] (default task-1) at org.jboss.as.ejb3.tx.CMTTxInterceptor.processInvocation(CMTTxInterceptor.java:239)

11:13:50,484 ERROR [stderr] (default task-1) at org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:309)

11:13:50,484 ERROR [stderr] (default task-1) at org.jboss.as.ejb3.component.interceptors.CurrentInvocationContextInterceptor.processInvocation(CurrentInvocationContextInterceptor.java:41)

11:13:50,484 ERROR [stderr] (default task-1) at org.jboss.invocation.InterceptorContext.proceed(InterceptorContext.java:309)

11:13:50,484 ERROR [stderr] (default task-1) at org.jboss.as.ejb3.component.invocationmetrics.WaitTimeInterceptor.processInvocation(WaitTimeInterceptor.java:43)