Can you try the url "tcp://artemis:61616?ha=true&reconnectAttempts=-1"?
Here -1 means infinite retry. Default reconnect attempts is
DEFAULT_RECONNECT_ATTEMPTS=0.
ahuhatwork <ahuhatw...@protonmail.com> 于2019年9月13日周五 下午11:23写道：
> Oh, that's unfortunate. I used the "< raw >" tag using nabble.
>
> Here is the artemis (2.9) client code snippet (hopefully this works):
>
> public class SampleProducer {
> public static void main(String[] args) throws JMSException,
> InterruptedException {
> String brokerUrl = "tcp://artemis:61616?ha=true";
> ConnectionFactory cf = new ActiveMQConnectionFactory(brokerUrl);
>
> try (Connection connection = cf.createConnection();
> Session session = connection.createSession(false,
> Session.AUTO_ACKNOWLEDGE)) {
> connection.start();
>
> Queue queue = session.createQueue("myJmsQueue");
> try (MessageProducer producer = session.createProducer(queue))
> {
> for (int i = 0; i < 500000; i++) {
> try {
> TextMessage message =
> session.createTextMessage("Message " + i);
> producer.send(message);
> } catch (JMSException e) {
> e.printStackTrace();
> }
> Thread.sleep(500);
> }
> }
> }
> }
> }
>
>
> Here is the exception that I get:
> javax.jms.IllegalStateException: Session is closed
> at
>
> org.apache.activemq.artemis.jms.client.ActiveMQSession.checkClosed(ActiveMQSession.java:1249)
> at
>
> org.apache.activemq.artemis.jms.client.ActiveMQSession.createTextMessage(ActiveMQSession.java:248)
>
>
>
> I do have a follow up question - is the sample code correct in terms of a
> producer handling automatic failover/failback?
>
>
>
> --
> Sent from:
> http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
>
