[ https://issues.apache.org/jira/browse/QPIDJMS-376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16432248#comment-16432248 ]
Daniel Maier commented on QPIDJMS-376: -------------------------------------- Ok, I will investigate why the server behaves this way. What do you mean with "use the consumer" exactly? This is the code I am using: {code:java} public static void main(String[] args) throws NamingException, JMSException, InterruptedException { final Hashtable<Object, Object> env = new Hashtable<>(); env.put(Context.INITIAL_CONTEXT_FACTORY, "org.apache.qpid.jms.jndi.JmsInitialContextFactory"); env.put("connectionfactory." + "cfid", "failover:(amqps://192.168.99.100:30071?amqp.saslMechanisms=PLAIN&transport.trustAll=true&" + "transport.verifyHost=false&amqp.traceFrames=true)?jms.username=perf_test_tenant&jms.password=secret&" + "initialReconnectDelay=10s&reconnectDelay=1s&maxReconnectDelay=1h&useReconnectBackOff=true&reconnectBackOffMultiplier=1m"); final Context ctx = new InitialContext(env); final ConnectionFactory cf = (ConnectionFactory) ctx.lookup("cfid"); final Connection connection = cf.createConnection(); connection.setExceptionListener(jmsException -> System.err.println(jmsException)); connection.setClientID("cfid"); connection.start(); MessageConsumer consumer = connection.createSession().createConsumer(new JmsQueue("telemetry/PERF_TEST_TENANT")); consumer.setMessageListener(message -> System.out.println(message)); Thread.currentThread().join(); } {code} I get no exception anywhere. Additionally: What is the expected behavior if the server closes the link after the link was established before? There is no way my client gets notified about that when I am using message listener? > Qpid JMS client does not notify user nor retries link establishment after > server closes receiver link > ----------------------------------------------------------------------------------------------------- > > Key: QPIDJMS-376 > URL: https://issues.apache.org/jira/browse/QPIDJMS-376 > Project: Qpid JMS > Issue Type: Bug > Components: qpid-jms-client > Affects Versions: 0.31.0 > Environment: AMQP Server: Enmasse 0.17.1 > Enmasse Address Type: anycast > Reporter: Daniel Maier > Priority: Major > Attachments: clientlogs.txt > > > When I create a consumer to an address that just does not exist, I expected > to get some exception or that the client retries the operation. But there > seems not even to be a log message which indicates a failure. > Is this intended behavior or is this a bug? A more general description is: If > AMQP server closes the receiver link, qpid jms client does not notify the > user anyhow or does not re-establish the link. -- This message was sent by Atlassian JIRA (v7.6.3#76005) --------------------------------------------------------------------- To unsubscribe, e-mail: dev-unsubscr...@qpid.apache.org For additional commands, e-mail: dev-h...@qpid.apache.org