You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by rudra1in <ru...@gmail.com> on 2020/03/25 13:27:23 UTC

ActiveMQ artemis listener not working

HI All , 
I am not able to receive message.
 
I am using ArtemisMQ with spring boot.
I am using spring boot auto configuration (
https://github.com/spring-projects/spring-boot/tree/master/spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/jms/artemis
<https://github.com/spring-projects/spring-boot/tree/master/spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/jms/artemis> 
)

Following are properties(application.properties)
spring.artemis.port=61616
spring.artemis.user=svc_enter
spring.artemis.password=svc_enter
spring.artemis.host=localhost
spring.artemis.mode=embedded
spring.artemis.embedded.enabled=true
spring.artemis.embedded.persistent=false
spring.artemis.embedded.queues= synchservice,testQUeue
spring.jms.cache.enabled=false

Below are my codes UserSynchConfiguration.java
<http://activemq.2283324.n4.nabble.com/file/t379847/UserSynchConfiguration.java>  
AddRequestQueueListener.java
<http://activemq.2283324.n4.nabble.com/file/t379847/AddRequestQueueListener.java>  
AddRequestSender.java
<http://activemq.2283324.n4.nabble.com/file/t379847/AddRequestSender.java>  

Below are the messages in console
2020-03-25 18:35:35,050 INFO  [Thread-2
(ActiveMQ-remoting-threads-ActiveMQServerImpl::serverUUID=442ca725-6e99-11ea-9830-340286d42c4f-1537371824)]
org.apache.activemq.artemis.logs.AuditLogger: AMQ601267: User anonymous is
creating a core session on target resource
ActiveMQServerImpl::serverUUID=442ca725-6e99-11ea-9830-340286d42c4f [with
parameters: [50a89b52-6e99-11ea-9830-340286d42c4f, null, ****, 102400,
RemotingConnectionImpl [ID=50a8261f-6e99-11ea-9830-340286d42c4f,
clientID=null, nodeID=442ca725-6e99-11ea-9830-340286d42c4f,
transportConnection=InVMConnection [serverID=0,
id=50a8261f-6e99-11ea-9830-340286d42c4f]], false, false, false, false, null,
org.apache.activemq.artemis.core.protocol.core.impl.CoreSessionCallback@8855b7f,
true,
org.apache.activemq.artemis.core.persistence.impl.nullpm.NullStorageManager$2@4e747756,
anonymous]]
2020-03-25 18:35:35,052 INFO  [Thread-2
(ActiveMQ-remoting-threads-ActiveMQServerImpl::serverUUID=442ca725-6e99-11ea-9830-340286d42c4f-1537371824)]
org.apache.activemq.artemis.logs.AuditLogger: AMQ601267: User anonymous is
creating a core session on target resource
ActiveMQServerImpl::serverUUID=442ca725-6e99-11ea-9830-340286d42c4f [with
parameters: [50a8c263-6e99-11ea-9830-340286d42c4f, null, ****, 102400,
RemotingConnectionImpl [ID=50a8261f-6e99-11ea-9830-340286d42c4f,
clientID=null, nodeID=442ca725-6e99-11ea-9830-340286d42c4f,
transportConnection=InVMConnection [serverID=0,
id=50a8261f-6e99-11ea-9830-340286d42c4f]], true, true, false, false, null,
org.apache.activemq.artemis.core.protocol.core.impl.CoreSessionCallback@438f089,
true,
org.apache.activemq.artemis.core.persistence.impl.nullpm.NullStorageManager$2@4e747756,
anonymous]]
2020-03-25 18:35:35,056 INFO  [Thread-4
(ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$6@33d53216)]
org.apache.activemq.artemis.logs.AuditLogger: AMQ601262: User anonymous is
creating address on target resource: 50a8c263-6e99-11ea-9830-340286d42c4f
[with parameters: [testQueue, [ANYCAST], true]]
2020-03-25 18:35:35,057 INFO  [Thread-4
(ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$6@33d53216)]
org.apache.activemq.artemis.logs.AuditLogger: AMQ601019: User anonymous is
getting mbean info on target resource:
org.apache.activemq.artemis.core.management.impl.AddressControlImpl@34781d9c
[]
2020-03-25 18:35:35,067 INFO  [Thread-2
(ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$6@33d53216)]
org.apache.activemq.artemis.logs.AuditLogger: AMQ601065: User anonymous is
creating a queue on target resource: ServerSessionImpl(jms-session=*N/A*)
[with parameters: [Address [name=testQueue, id=0, routingTypes={ANYCAST},
autoCreated=false, paused=false], testQueue, null, false, true, -1, false,
false, false, -1, null, false, null, false, 0, -1, true, 0, 0, true]]
2020-03-25 18:35:35,069 INFO  [Thread-2
(ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$6@33d53216)]
org.apache.activemq.artemis.logs.AuditLogger: AMQ601019: User anonymous is
getting mbean info on target resource:
org.apache.activemq.artemis.core.management.impl.QueueControlImpl@5f83f6c5
[]
2020-03-25 18:35:35,092 INFO  [Thread-7
(ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$6@33d53216)]
org.apache.activemq.artemis.logs.AuditLogger: AMQ601500: User anonymous is
sending a core message on target resource:
ServerSessionImpl(jms-session=*N/A*) [with parameters: [TransactionImpl
[xid=null, txID=279, xid=null, state=ACTIVE, createTime=1585141535052(Wed
Mar 25 18:35:35 IST 2020), timeoutSeconds=300, nr operations = 0]@5f6c99d7,
CoreMessage[messageID=0,durable=true,userID=50ae1995-6e99-11ea-9830-340286d42c4f,priority=4,
timestamp=Wed Mar 25 18:35:35 IST 2020,expiration=0, durable=true,
address=testQueue,size=351,properties=TypedProperties[messageCount=0,__AMQ_CID=50a87441-6e99-11ea-9830-340286d42c4f,_AMQ_ROUTING_TYPE=1]]@2082863035,
false, false, RoutingContextImpl(Address=null, routingType=null,
PreviousAddress=null previousRoute:null, reusable=null, version=0)
..................................................
]]
2020-03-25 18:35:35,135 INFO  [Thread-3
(ActiveMQ-remoting-threads-ActiveMQServerImpl::serverUUID=442ca725-6e99-11ea-9830-340286d42c4f-1537371824)]
org.apache.activemq.artemis.logs.AuditLogger: AMQ601267: User anonymous is
creating a core session on target resource
ActiveMQServerImpl::serverUUID=442ca725-6e99-11ea-9830-340286d42c4f [with
parameters: [50b56c99-6e99-11ea-9830-340286d42c4f, null, ****, 102400,
RemotingConnectionImpl [ID=50b54586-6e99-11ea-9830-340286d42c4f,
clientID=null, nodeID=442ca725-6e99-11ea-9830-340286d42c4f,
transportConnection=InVMConnection [serverID=0,
id=50b54586-6e99-11ea-9830-340286d42c4f]], false, false, false, false, null,
org.apache.activemq.artemis.core.protocol.core.impl.CoreSessionCallback@4d809d76,
true,
org.apache.activemq.artemis.core.persistence.impl.nullpm.NullStorageManager$2@4e747756,
anonymous]]
2020-03-25 18:35:35,137 INFO  [Thread-3
(ActiveMQ-remoting-threads-ActiveMQServerImpl::serverUUID=442ca725-6e99-11ea-9830-340286d42c4f-1537371824)]
org.apache.activemq.artemis.logs.AuditLogger: AMQ601267: User anonymous is
creating a core session on target resource
ActiveMQServerImpl::serverUUID=442ca725-6e99-11ea-9830-340286d42c4f [with
parameters: [50b5baba-6e99-11ea-9830-340286d42c4f, null, ****, 102400,
RemotingConnectionImpl [ID=50b54586-6e99-11ea-9830-340286d42c4f,
clientID=null, nodeID=442ca725-6e99-11ea-9830-340286d42c4f,
transportConnection=InVMConnection [serverID=0,
id=50b54586-6e99-11ea-9830-340286d42c4f]], true, true, false, false, null,
org.apache.activemq.artemis.core.protocol.core.impl.CoreSessionCallback@4778f606,
true,
org.apache.activemq.artemis.core.persistence.impl.nullpm.NullStorageManager$2@4e747756,
anonymous]]
2020-03-25 18:35:35,142 INFO  [Thread-5
(ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$6@33d53216)]
org.apache.activemq.artemis.logs.AuditLogger: AMQ601500: User anonymous is
sending a core message on target resource:
ServerSessionImpl(jms-session=*N/A*) [with parameters: [TransactionImpl
[xid=null, txID=292, xid=null, state=ACTIVE, createTime=1585141535137(Wed
Mar 25 18:35:35 IST 2020), timeoutSeconds=300, nr operations = 0]@3d0b4740,
CoreMessage[messageID=0,durable=true,userID=50b656fb-6e99-11ea-9830-340286d42c4f,priority=4,
timestamp=Wed Mar 25 18:35:35 IST 2020,expiration=0, durable=true,
address=testQueue,size=351,properties=TypedProperties[messageCount=1,__AMQ_CID=50b56c98-6e99-11ea-9830-340286d42c4f,_AMQ_ROUTING_TYPE=1]]@869056145,
false, false, RoutingContextImpl(Address=null, routingType=null,
PreviousAddress=null previousRoute:null, reusable=null, version=0)
..................................................
]]
2020-03-25 18:35:35,149 INFO  [Thread-3
(ActiveMQ-remoting-threads-ActiveMQServerImpl::serverUUID=442ca725-6e99-11ea-9830-340286d42c4f-1537371824)]
org.apache.activemq.artemis.logs.AuditLogger: AMQ601267: User anonymous is
creating a core session on target resource
ActiveMQServerImpl::serverUUID=442ca725-6e99-11ea-9830-340286d42c4f [with
parameters: [50b78f7f-6e99-11ea-9830-340286d42c4f, null, ****, 102400,
RemotingConnectionImpl [ID=50b7686c-6e99-11ea-9830-340286d42c4f,
clientID=null, nodeID=442ca725-6e99-11ea-9830-340286d42c4f,
transportConnection=InVMConnection [serverID=0,
id=50b7686c-6e99-11ea-9830-340286d42c4f]], false, false, false, false, null,
org.apache.activemq.artemis.core.protocol.core.impl.CoreSessionCallback@4bd83699,
true,
org.apache.activemq.artemis.core.persistence.impl.nullpm.NullStorageManager$2@4e747756,
anonymous]]
2020-03-25 18:35:35,150 INFO  [Thread-3
(ActiveMQ-remoting-threads-ActiveMQServerImpl::serverUUID=442ca725-6e99-11ea-9830-340286d42c4f-1537371824)]
org.apache.activemq.artemis.logs.AuditLogger: AMQ601267: User anonymous is
creating a core session on target resource
ActiveMQServerImpl::serverUUID=442ca725-6e99-11ea-9830-340286d42c4f [with
parameters: [50b7dda0-6e99-11ea-9830-340286d42c4f, null, ****, 102400,
RemotingConnectionImpl [ID=50b7686c-6e99-11ea-9830-340286d42c4f,
clientID=null, nodeID=442ca725-6e99-11ea-9830-340286d42c4f,
transportConnection=InVMConnection [serverID=0,
id=50b7686c-6e99-11ea-9830-340286d42c4f]], true, true, false, false, null,
org.apache.activemq.artemis.core.protocol.core.impl.CoreSessionCallback@337a6f38,
true,
org.apache.activemq.artemis.core.persistence.impl.nullpm.NullStorageManager$2@4e747756,
anonymous]]
2020-03-25 18:35:35,155 INFO  [Thread-11
(ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$6@33d53216)]
org.apache.activemq.artemis.logs.AuditLogger: AMQ601500: User anonymous is
sending a core message on target resource:
ServerSessionImpl(jms-session=*N/A*) [with parameters: [TransactionImpl
[xid=null, txID=301, xid=null, state=ACTIVE, createTime=1585141535151(Wed
Mar 25 18:35:35 IST 2020), timeoutSeconds=300, nr operations = 0]@36b10006,
CoreMessage[messageID=0,durable=true,userID=50b852d1-6e99-11ea-9830-340286d42c4f,priority=4,
timestamp=Wed Mar 25 18:35:35 IST 2020,expiration=0, durable=true,
address=testQueue,size=351,properties=TypedProperties[messageCount=2,__AMQ_CID=50b78f7e-6e99-11ea-9830-340286d42c4f,_AMQ_ROUTING_TYPE=1]]@947320992,
false, false, RoutingContextImpl(Address=null, routingType=null,
PreviousAddress=null previousRoute:null, reusable=null, version=0)
..................................................
]]
2020-03-25 18:35:35,161 INFO  [Thread-2
(ActiveMQ-remoting-threads-ActiveMQServerImpl::serverUUID=442ca725-6e99-11ea-9830-340286d42c4f-1537371824)]
org.apache.activemq.artemis.logs.AuditLogger: AMQ601267: User anonymous is
creating a core session on target resource
ActiveMQServerImpl::serverUUID=442ca725-6e99-11ea-9830-340286d42c4f [with
parameters: [50b98b55-6e99-11ea-9830-340286d42c4f, null, ****, 102400,
RemotingConnectionImpl [ID=50b96442-6e99-11ea-9830-340286d42c4f,
clientID=null, nodeID=442ca725-6e99-11ea-9830-340286d42c4f,
transportConnection=InVMConnection [serverID=0,
id=50b96442-6e99-11ea-9830-340286d42c4f]], false, false, false, false, null,
org.apache.activemq.artemis.core.protocol.core.impl.CoreSessionCallback@ccba753,
true,
org.apache.activemq.artemis.core.persistence.impl.nullpm.NullStorageManager$2@4e747756,
anonymous]]
2020-03-25 18:35:35,163 INFO  [Thread-2
(ActiveMQ-remoting-threads-ActiveMQServerImpl::serverUUID=442ca725-6e99-11ea-9830-340286d42c4f-1537371824)]
org.apache.activemq.artemis.logs.AuditLogger: AMQ601267: User anonymous is
creating a core session on target resource
ActiveMQServerImpl::serverUUID=442ca725-6e99-11ea-9830-340286d42c4f [with
parameters: [50b9b266-6e99-11ea-9830-340286d42c4f, null, ****, 102400,
RemotingConnectionImpl [ID=50b96442-6e99-11ea-9830-340286d42c4f,
clientID=null, nodeID=442ca725-6e99-11ea-9830-340286d42c4f,
transportConnection=InVMConnection [serverID=0,
id=50b96442-6e99-11ea-9830-340286d42c4f]], true, true, false, false, null,
org.apache.activemq.artemis.core.protocol.core.impl.CoreSessionCallback@5510453b,
true,
org.apache.activemq.artemis.core.persistence.impl.nullpm.NullStorageManager$2@4e747756,
anonymous]]
2020-03-25 18:35:35,166 INFO  [Thread-16
(ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$6@33d53216)]
org.apache.activemq.artemis.logs.AuditLogger: AMQ601500: User anonymous is
sending a core message on target resource:
ServerSessionImpl(jms-session=*N/A*) [with parameters: [TransactionImpl
[xid=null, txID=310, xid=null, state=ACTIVE, createTime=1585141535163(Wed
Mar 25 18:35:35 IST 2020), timeoutSeconds=300, nr operations = 0]@19ae13b2,
CoreMessage[messageID=0,durable=true,userID=50ba0087-6e99-11ea-9830-340286d42c4f,priority=4,
timestamp=Wed Mar 25 18:35:35 IST 2020,expiration=0, durable=true,
address=testQueue,size=351,properties=TypedProperties[messageCount=3,__AMQ_CID=50b98b54-6e99-11ea-9830-340286d42c4f,_AMQ_ROUTING_TYPE=1]]@1492174673,
false, false, RoutingContextImpl(Address=null, routingType=null,
PreviousAddress=null previousRoute:null, reusable=null, version=0)
..................................................
]]
2020-03-25 18:35:35,170 INFO  [Thread-2
(ActiveMQ-remoting-threads-ActiveMQServerImpl::serverUUID=442ca725-6e99-11ea-9830-340286d42c4f-1537371824)]
org.apache.activemq.artemis.logs.AuditLogger: AMQ601267: User anonymous is
creating a core session on target resource
ActiveMQServerImpl::serverUUID=442ca725-6e99-11ea-9830-340286d42c4f [with
parameters: [50baeaeb-6e99-11ea-9830-340286d42c4f, null, ****, 102400,
RemotingConnectionImpl [ID=50bac3d8-6e99-11ea-9830-340286d42c4f,
clientID=null, nodeID=442ca725-6e99-11ea-9830-340286d42c4f,
transportConnection=InVMConnection [serverID=0,
id=50bac3d8-6e99-11ea-9830-340286d42c4f]], false, false, false, false, null,
org.apache.activemq.artemis.core.protocol.core.impl.CoreSessionCallback@10e9c392,
true,
org.apache.activemq.artemis.core.persistence.impl.nullpm.NullStorageManager$2@4e747756,
anonymous]]
2020-03-25 18:35:35,172 INFO  [Thread-2
(ActiveMQ-remoting-threads-ActiveMQServerImpl::serverUUID=442ca725-6e99-11ea-9830-340286d42c4f-1537371824)]
org.apache.activemq.artemis.logs.AuditLogger: AMQ601267: User anonymous is
creating a core session on target resource
ActiveMQServerImpl::serverUUID=442ca725-6e99-11ea-9830-340286d42c4f [with
parameters: [50bb390c-6e99-11ea-9830-340286d42c4f, null, ****, 102400,
RemotingConnectionImpl [ID=50bac3d8-6e99-11ea-9830-340286d42c4f,
clientID=null, nodeID=442ca725-6e99-11ea-9830-340286d42c4f,
transportConnection=InVMConnection [serverID=0,
id=50bac3d8-6e99-11ea-9830-340286d42c4f]], true, true, false, false, null,
org.apache.activemq.artemis.core.protocol.core.impl.CoreSessionCallback@2b9a608b,
true,
org.apache.activemq.artemis.core.persistence.impl.nullpm.NullStorageManager$2@4e747756,
anonymous]]
2020-03-25 18:35:35,175 INFO  [Thread-12
(ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$6@33d53216)]
org.apache.activemq.artemis.logs.AuditLogger: AMQ601500: User anonymous is
sending a core message on target resource:
ServerSessionImpl(jms-session=*N/A*) [with parameters: [TransactionImpl
[xid=null, txID=319, xid=null, state=ACTIVE, createTime=1585141535173(Wed
Mar 25 18:35:35 IST 2020), timeoutSeconds=300, nr operations = 0]@539050e9,
CoreMessage[messageID=0,durable=true,userID=50bb872d-6e99-11ea-9830-340286d42c4f,priority=4,
timestamp=Wed Mar 25 18:35:35 IST 2020,expiration=0, durable=true,
address=testQueue,size=351,properties=TypedProperties[messageCount=4,__AMQ_CID=50baeaea-6e99-11ea-9830-340286d42c4f,_AMQ_ROUTING_TYPE=1]]@1566024939,
false, false, RoutingContextImpl(Address=null, routingType=null,
PreviousAddress=null previousRoute:null, reusable=null, version=0)
..................................................
]]



--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Re: ActiveMQ artemis listener not working

Posted by rudra1in <ru...@gmail.com>.
Thanks brusdev, there is a problem in client making duplicate calls.



--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Re: ActiveMQ artemis listener not working

Posted by Justin Bertram <jb...@apache.org>.
Domenico is right. Using JmsTemplate will create a connection, session, &
producer for *every* message sent. This is a significant anti-pattern
discussed here [1] and here [2].


Justin

[1]
http://activemq.apache.org/components/artemis/documentation/latest/perf-tuning.html#avoiding-anti-patterns
[2] https://activemq.apache.org/jmstemplate-gotchas

On Wed, Mar 25, 2020 at 8:43 PM brusdev <br...@gmail.com> wrote:

> Hi,
>
> the JmsTemplate creates a new session for each message to send, according
> to
> its source[1].
> So in the broker log you can find the lines relative the session creating
> and the message sending for each of the 5 messages sent by
> `sender.sendmessages`.
>
> [1]
>
> https://github.com/spring-projects/spring-framework/blob/v5.1.7.RELEASE/spring-jms/src/main/java/org/springframework/jms/core/JmsTemplate.java#L495
>
> Regards,
> Domenico
>
>
>
> --
> Sent from:
> http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
>
>

Re: ActiveMQ artemis listener not working

Posted by brusdev <br...@gmail.com>.
Hi,

the JmsTemplate creates a new session for each message to send, according to
its source[1].
So in the broker log you can find the lines relative the session creating
and the message sending for each of the 5 messages sent by
`sender.sendmessages`.

[1]
https://github.com/spring-projects/spring-framework/blob/v5.1.7.RELEASE/spring-jms/src/main/java/org/springframework/jms/core/JmsTemplate.java#L495

Regards,
Domenico



--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Re: ActiveMQ artemis listener not working

Posted by rudra1in <ru...@gmail.com>.
I want to use embedded artemis MQ
I have one sender class and one listner tied to one queue.
import java.util.Date;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;
import javax.jms.TextMessage;

import org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;

public class AddRequestSender {
	
	 @Autowired
	 JmsTemplate testTemplate;
	 @Autowired
	  ActiveMQConnectionFactory jmsConnectionFactory;
	 private static final Logger LOGGER =
LoggerFactory.getLogger(AddRequestSender.class);
	
	public AddRequestSender() {
		
	}
	
	  public void sendMessages(String string) throws JMSException,
InterruptedException {
          StringBuilder payload = null;
         
          for (int i = 0; i < 5; ++i) {
              payload = new StringBuilder();
              payload.append("Message [").append(i).append("] sent at:
").append(new Date());
  final String payload1= payload.toString();
  final int j = i;
  
  testTemplate.send("testQUeue",new MessageCreator() {
                  public Message createMessage(Session session) throws
JMSException {
//               	
                      TextMessage message = session.createTextMessage();
                      message.setText(payload1);
                      message.setIntProperty("messageCount", j);
                      return message;
                  }
              });
   
          }
      
}

}

My listener class
import java.util.concurrent.atomic.AtomicInteger;

import javax.jms.Message;
import javax.jms.MessageListener;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;



public class AddRequestQueueListener implements MessageListener {
	AtomicInteger intx = new AtomicInteger();
	private static final Logger LOGGER =
LoggerFactory.getLogger(AddRequestQueueListener.class);
	@Override
	public void onMessage(Message message) {
		LOGGER.info("received testQUeue");
		LOGGER.info("received intx"+intx.incrementAndGet());
		
	}

}
When I am invoking sender.sendmessages only once,
I am getting output multiple times.
Below are logs.

2020-03-26 03:43:25,874 INFO  [Thread-2
(ActiveMQ-remoting-threads-ActiveMQServerImpl::serverUUID=ce49a3f9-6ee5-11ea-ae52-340286d42c4f-1943275118)]
org.apache.activemq.artemis.logs.AuditLogger: AMQ601267: User anonymous is
creating a core session on target resource
ActiveMQServerImpl::serverUUID=ce49a3f9-6ee5-11ea-ae52-340286d42c4f [with
parameters: [d932270e-6ee5-11ea-ae52-340286d42c4f, null, ****, 102400,
RemotingConnectionImpl [ID=d931d8eb-6ee5-11ea-ae52-340286d42c4f,
clientID=null, nodeID=ce49a3f9-6ee5-11ea-ae52-340286d42c4f,
transportConnection=InVMConnection [serverID=0,
id=d931d8eb-6ee5-11ea-ae52-340286d42c4f]], false, false, false, false, null,
org.apache.activemq.artemis.core.protocol.core.impl.CoreSessionCallback@4536128,
true,
org.apache.activemq.artemis.core.persistence.impl.nullpm.NullStorageManager$2@65259718,
anonymous]]
2020-03-26 03:43:25,876 INFO  [Thread-2
(ActiveMQ-remoting-threads-ActiveMQServerImpl::serverUUID=ce49a3f9-6ee5-11ea-ae52-340286d42c4f-1943275118)]
org.apache.activemq.artemis.logs.AuditLogger: AMQ601267: User anonymous is
creating a core session on target resource
ActiveMQServerImpl::serverUUID=ce49a3f9-6ee5-11ea-ae52-340286d42c4f [with
parameters: [d932752f-6ee5-11ea-ae52-340286d42c4f, null, ****, 102400,
RemotingConnectionImpl [ID=d931d8eb-6ee5-11ea-ae52-340286d42c4f,
clientID=null, nodeID=ce49a3f9-6ee5-11ea-ae52-340286d42c4f,
transportConnection=InVMConnection [serverID=0,
id=d931d8eb-6ee5-11ea-ae52-340286d42c4f]], true, true, false, false, null,
org.apache.activemq.artemis.core.protocol.core.impl.CoreSessionCallback@5daca19e,
true,
org.apache.activemq.artemis.core.persistence.impl.nullpm.NullStorageManager$2@65259718,
anonymous]]
2020-03-26 03:43:25,909 INFO  [Thread-13
(ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$6@165e389b)]
org.apache.activemq.artemis.logs.AuditLogger: AMQ601500: User anonymous is
sending a core message on target resource:
ServerSessionImpl(jms-session=*N/A*) [with parameters: [TransactionImpl
[xid=null, txID=249, xid=null, state=ACTIVE, createTime=1585174405876(Thu
Mar 26 03:43:25 IST 2020), timeoutSeconds=300, nr operations = 0]@32ba055b,
CoreMessage[messageID=0,durable=true,userID=d935f6a0-6ee5-11ea-ae52-340286d42c4f,priority=4,
timestamp=Thu Mar 26 03:43:25 IST 2020,expiration=0, durable=true,
address=testQUeue,size=351,properties=TypedProperties[messageCount=0,__AMQ_CID=d932270d-6ee5-11ea-ae52-340286d42c4f,_AMQ_ROUTING_TYPE=1]]@961604013,
false, false, RoutingContextImpl(Address=null, routingType=null,
PreviousAddress=null previousRoute:null, reusable=null, version=0)
..................................................
]]
2020-03-26 03:43:25,944 INFO  [Thread-0 (ActiveMQ-client-global-threads)]
com.adidas.enter.users.robot.jms.AddRequestQueueListener: received testQUeue
2020-03-26 03:43:25,945 INFO  [Thread-0 (ActiveMQ-client-global-threads)]
com.adidas.enter.users.robot.jms.AddRequestQueueListener: received intx1
2020-03-26 03:43:26,024 INFO  [Thread-2
(ActiveMQ-remoting-threads-ActiveMQServerImpl::serverUUID=ce49a3f9-6ee5-11ea-ae52-340286d42c4f-1943275118)]
org.apache.activemq.artemis.logs.AuditLogger: AMQ601267: User anonymous is
creating a core session on target resource
ActiveMQServerImpl::serverUUID=ce49a3f9-6ee5-11ea-ae52-340286d42c4f [with
parameters: [d9493084-6ee5-11ea-ae52-340286d42c4f, null, ****, 102400,
RemotingConnectionImpl [ID=d948bb51-6ee5-11ea-ae52-340286d42c4f,
clientID=null, nodeID=ce49a3f9-6ee5-11ea-ae52-340286d42c4f,
transportConnection=InVMConnection [serverID=0,
id=d948bb51-6ee5-11ea-ae52-340286d42c4f]], false, false, false, false, null,
org.apache.activemq.artemis.core.protocol.core.impl.CoreSessionCallback@49bdaa27,
true,
org.apache.activemq.artemis.core.persistence.impl.nullpm.NullStorageManager$2@65259718,
anonymous]]
2020-03-26 03:43:26,025 INFO  [Thread-2
(ActiveMQ-remoting-threads-ActiveMQServerImpl::serverUUID=ce49a3f9-6ee5-11ea-ae52-340286d42c4f-1943275118)]
org.apache.activemq.artemis.logs.AuditLogger: AMQ601267: User anonymous is
creating a core session on target resource
ActiveMQServerImpl::serverUUID=ce49a3f9-6ee5-11ea-ae52-340286d42c4f [with
parameters: [d9495795-6ee5-11ea-ae52-340286d42c4f, null, ****, 102400,
RemotingConnectionImpl [ID=d948bb51-6ee5-11ea-ae52-340286d42c4f,
clientID=null, nodeID=ce49a3f9-6ee5-11ea-ae52-340286d42c4f,
transportConnection=InVMConnection [serverID=0,
id=d948bb51-6ee5-11ea-ae52-340286d42c4f]], true, true, false, false, null,
org.apache.activemq.artemis.core.protocol.core.impl.CoreSessionCallback@45a39a80,
true,
org.apache.activemq.artemis.core.persistence.impl.nullpm.NullStorageManager$2@65259718,
anonymous]]
2020-03-26 03:43:26,028 INFO  [Thread-12
(ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$6@165e389b)]
org.apache.activemq.artemis.logs.AuditLogger: AMQ601500: User anonymous is
sending a core message on target resource:
ServerSessionImpl(jms-session=*N/A*) [with parameters: [TransactionImpl
[xid=null, txID=259, xid=null, state=ACTIVE, createTime=1585174406026(Thu
Mar 26 03:43:26 IST 2020), timeoutSeconds=300, nr operations = 0]@38a9ef30,
CoreMessage[messageID=0,durable=true,userID=d949a5b6-6ee5-11ea-ae52-340286d42c4f,priority=4,
timestamp=Thu Mar 26 03:43:26 IST 2020,expiration=0, durable=true,
address=testQUeue,size=351,properties=TypedProperties[messageCount=1,__AMQ_CID=d9490973-6ee5-11ea-ae52-340286d42c4f,_AMQ_ROUTING_TYPE=1]]@1016491261,
false, false, RoutingContextImpl(Address=null, routingType=null,
PreviousAddress=null previousRoute:null, reusable=null, version=0)
..................................................
]]
2020-03-26 03:43:26,032 INFO  [Thread-0 (ActiveMQ-client-global-threads)]
com.adidas.enter.users.robot.jms.AddRequestQueueListener: received testQUeue
2020-03-26 03:43:26,032 INFO  [Thread-0 (ActiveMQ-client-global-threads)]
com.adidas.enter.users.robot.jms.AddRequestQueueListener: received intx2
2020-03-26 03:43:26,056 INFO  [Thread-2
(ActiveMQ-remoting-threads-ActiveMQServerImpl::serverUUID=ce49a3f9-6ee5-11ea-ae52-340286d42c4f-1943275118)]
org.apache.activemq.artemis.logs.AuditLogger: AMQ601267: User anonymous is
creating a core session on target resource
ActiveMQServerImpl::serverUUID=ce49a3f9-6ee5-11ea-ae52-340286d42c4f [with
parameters: [d94deb7a-6ee5-11ea-ae52-340286d42c4f, null, ****, 102400,
RemotingConnectionImpl [ID=d94dc467-6ee5-11ea-ae52-340286d42c4f,
clientID=null, nodeID=ce49a3f9-6ee5-11ea-ae52-340286d42c4f,
transportConnection=InVMConnection [serverID=0,
id=d94dc467-6ee5-11ea-ae52-340286d42c4f]], false, false, false, false, null,
org.apache.activemq.artemis.core.protocol.core.impl.CoreSessionCallback@6160fcab,
true,
org.apache.activemq.artemis.core.persistence.impl.nullpm.NullStorageManager$2@65259718,
anonymous]]
2020-03-26 03:43:26,058 INFO  [Thread-2
(ActiveMQ-remoting-threads-ActiveMQServerImpl::serverUUID=ce49a3f9-6ee5-11ea-ae52-340286d42c4f-1943275118)]
org.apache.activemq.artemis.logs.AuditLogger: AMQ601267: User anonymous is
creating a core session on target resource
ActiveMQServerImpl::serverUUID=ce49a3f9-6ee5-11ea-ae52-340286d42c4f [with
parameters: [d94e399b-6ee5-11ea-ae52-340286d42c4f, null, ****, 102400,
RemotingConnectionImpl [ID=d94dc467-6ee5-11ea-ae52-340286d42c4f,
clientID=null, nodeID=ce49a3f9-6ee5-11ea-ae52-340286d42c4f,
transportConnection=InVMConnection [serverID=0,
id=d94dc467-6ee5-11ea-ae52-340286d42c4f]], true, true, false, false, null,
org.apache.activemq.artemis.core.protocol.core.impl.CoreSessionCallback@63a693b9,
true,
org.apache.activemq.artemis.core.persistence.impl.nullpm.NullStorageManager$2@65259718,
anonymous]]
2020-03-26 03:43:26,061 INFO  [Thread-0
(ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$6@165e389b)]
org.apache.activemq.artemis.logs.AuditLogger: AMQ601500: User anonymous is
sending a core message on target resource:
ServerSessionImpl(jms-session=*N/A*) [with parameters: [TransactionImpl
[xid=null, txID=269, xid=null, state=ACTIVE, createTime=1585174406058(Thu
Mar 26 03:43:26 IST 2020), timeoutSeconds=300, nr operations = 0]@14919b99,
CoreMessage[messageID=0,durable=true,userID=d94e87bc-6ee5-11ea-ae52-340286d42c4f,priority=4,
timestamp=Thu Mar 26 03:43:26 IST 2020,expiration=0, durable=true,
address=testQUeue,size=351,properties=TypedProperties[messageCount=2,__AMQ_CID=d94deb79-6ee5-11ea-ae52-340286d42c4f,_AMQ_ROUTING_TYPE=1]]@991804096,
false, false, RoutingContextImpl(Address=null, routingType=null,
PreviousAddress=null previousRoute:null, reusable=null, version=0)
..................................................
]]
2020-03-26 03:43:26,064 INFO  [Thread-0 (ActiveMQ-client-global-threads)]
com.adidas.enter.users.robot.jms.AddRequestQueueListener: received testQUeue
2020-03-26 03:43:26,065 INFO  [Thread-0 (ActiveMQ-client-global-threads)]
com.adidas.enter.users.robot.jms.AddRequestQueueListener: received intx3
2020-03-26 03:43:26,069 INFO  [Thread-1
(ActiveMQ-remoting-threads-ActiveMQServerImpl::serverUUID=ce49a3f9-6ee5-11ea-ae52-340286d42c4f-1943275118)]
org.apache.activemq.artemis.logs.AuditLogger: AMQ601267: User anonymous is
creating a core session on target resource
ActiveMQServerImpl::serverUUID=ce49a3f9-6ee5-11ea-ae52-340286d42c4f [with
parameters: [d94fe750-6ee5-11ea-ae52-340286d42c4f, null, ****, 102400,
RemotingConnectionImpl [ID=d94fc03d-6ee5-11ea-ae52-340286d42c4f,
clientID=null, nodeID=ce49a3f9-6ee5-11ea-ae52-340286d42c4f,
transportConnection=InVMConnection [serverID=0,
id=d94fc03d-6ee5-11ea-ae52-340286d42c4f]], false, false, false, false, null,
org.apache.activemq.artemis.core.protocol.core.impl.CoreSessionCallback@48a89417,
true,
org.apache.activemq.artemis.core.persistence.impl.nullpm.NullStorageManager$2@65259718,
anonymous]]
2020-03-26 03:43:26,071 INFO  [Thread-1
(ActiveMQ-remoting-threads-ActiveMQServerImpl::serverUUID=ce49a3f9-6ee5-11ea-ae52-340286d42c4f-1943275118)]
org.apache.activemq.artemis.logs.AuditLogger: AMQ601267: User anonymous is
creating a core session on target resource
ActiveMQServerImpl::serverUUID=ce49a3f9-6ee5-11ea-ae52-340286d42c4f [with
parameters: [d9503571-6ee5-11ea-ae52-340286d42c4f, null, ****, 102400,
RemotingConnectionImpl [ID=d94fc03d-6ee5-11ea-ae52-340286d42c4f,
clientID=null, nodeID=ce49a3f9-6ee5-11ea-ae52-340286d42c4f,
transportConnection=InVMConnection [serverID=0,
id=d94fc03d-6ee5-11ea-ae52-340286d42c4f]], true, true, false, false, null,
org.apache.activemq.artemis.core.protocol.core.impl.CoreSessionCallback@2f856ecd,
true,
org.apache.activemq.artemis.core.persistence.impl.nullpm.NullStorageManager$2@65259718,
anonymous]]
2020-03-26 03:43:26,074 INFO  [Thread-6
(ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$6@165e389b)]
org.apache.activemq.artemis.logs.AuditLogger: AMQ601500: User anonymous is
sending a core message on target resource:
ServerSessionImpl(jms-session=*N/A*) [with parameters: [TransactionImpl
[xid=null, txID=279, xid=null, state=ACTIVE, createTime=1585174406071(Thu
Mar 26 03:43:26 IST 2020), timeoutSeconds=300, nr operations = 0]@224c494e,
CoreMessage[messageID=0,durable=true,userID=d950aaa2-6ee5-11ea-ae52-340286d42c4f,priority=4,
timestamp=Thu Mar 26 03:43:26 IST 2020,expiration=0, durable=true,
address=testQUeue,size=351,properties=TypedProperties[messageCount=3,__AMQ_CID=d94fe74f-6ee5-11ea-ae52-340286d42c4f,_AMQ_ROUTING_TYPE=1]]@1238541389,
false, false, RoutingContextImpl(Address=null, routingType=null,
PreviousAddress=null previousRoute:null, reusable=null, version=0)
..................................................
]]
2020-03-26 03:43:26,078 INFO  [Thread-0 (ActiveMQ-client-global-threads)]
com.adidas.enter.users.robot.jms.AddRequestQueueListener: received testQUeue
2020-03-26 03:43:26,079 INFO  [Thread-0 (ActiveMQ-client-global-threads)]
com.adidas.enter.users.robot.jms.AddRequestQueueListener: received intx4
2020-03-26 03:43:26,083 INFO  [Thread-1
(ActiveMQ-remoting-threads-ActiveMQServerImpl::serverUUID=ce49a3f9-6ee5-11ea-ae52-340286d42c4f-1943275118)]
org.apache.activemq.artemis.logs.AuditLogger: AMQ601267: User anonymous is
creating a core session on target resource
ActiveMQServerImpl::serverUUID=ce49a3f9-6ee5-11ea-ae52-340286d42c4f [with
parameters: [d9520a36-6ee5-11ea-ae52-340286d42c4f, null, ****, 102400,
RemotingConnectionImpl [ID=d951e323-6ee5-11ea-ae52-340286d42c4f,
clientID=null, nodeID=ce49a3f9-6ee5-11ea-ae52-340286d42c4f,
transportConnection=InVMConnection [serverID=0,
id=d951e323-6ee5-11ea-ae52-340286d42c4f]], false, false, false, false, null,
org.apache.activemq.artemis.core.protocol.core.impl.CoreSessionCallback@7784834c,
true,
org.apache.activemq.artemis.core.persistence.impl.nullpm.NullStorageManager$2@65259718,
anonymous]]
2020-03-26 03:43:26,085 INFO  [Thread-1
(ActiveMQ-remoting-threads-ActiveMQServerImpl::serverUUID=ce49a3f9-6ee5-11ea-ae52-340286d42c4f-1943275118)]
org.apache.activemq.artemis.logs.AuditLogger: AMQ601267: User anonymous is
creating a core session on target resource
ActiveMQServerImpl::serverUUID=ce49a3f9-6ee5-11ea-ae52-340286d42c4f [with
parameters: [d9525857-6ee5-11ea-ae52-340286d42c4f, null, ****, 102400,
RemotingConnectionImpl [ID=d951e323-6ee5-11ea-ae52-340286d42c4f,
clientID=null, nodeID=ce49a3f9-6ee5-11ea-ae52-340286d42c4f,
transportConnection=InVMConnection [serverID=0,
id=d951e323-6ee5-11ea-ae52-340286d42c4f]], true, true, false, false, null,
org.apache.activemq.artemis.core.protocol.core.impl.CoreSessionCallback@52bdd19d,
true,
org.apache.activemq.artemis.core.persistence.impl.nullpm.NullStorageManager$2@65259718,
anonymous]]
2020-03-26 03:43:26,090 INFO  [Thread-12
(ActiveMQ-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$6@165e389b)]
org.apache.activemq.artemis.logs.AuditLogger: AMQ601500: User anonymous is
sending a core message on target resource:
ServerSessionImpl(jms-session=*N/A*) [with parameters: [TransactionImpl
[xid=null, txID=289, xid=null, state=ACTIVE, createTime=1585174406085(Thu
Mar 26 03:43:26 IST 2020), timeoutSeconds=300, nr operations = 0]@3f00d7db,
CoreMessage[messageID=0,durable=true,userID=d952f498-6ee5-11ea-ae52-340286d42c4f,priority=4,
timestamp=Thu Mar 26 03:43:26 IST 2020,expiration=0, durable=true,
address=testQUeue,size=351,properties=TypedProperties[messageCount=4,__AMQ_CID=d9520a35-6ee5-11ea-ae52-340286d42c4f,_AMQ_ROUTING_TYPE=1]]@1218936676,
false, false, RoutingContextImpl(Address=null, routingType=null,
PreviousAddress=null previousRoute:null, reusable=null, version=0)
..................................................
]]
2020-03-26 03:43:26,092 INFO  [Thread-0 (ActiveMQ-client-global-threads)]
com.adidas.enter.users.robot.jms.AddRequestQueueListener: received testQUeue
2020-03-26 03:43:26,093 INFO  [Thread-0 (ActiveMQ-client-global-threads)]
com.adidas.enter.users.robot.jms.AddRequestQueueListener: received intx5

Thanks in advance,
Rudra



--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Re: ActiveMQ artemis listener not working

Posted by Justin Bertram <jb...@apache.org>.
I'd like to help, but I really don't understand what you're asking. Can you
elaborate on your use-case and the behavior you're seeing?


Justin

On Wed, Mar 25, 2020 at 11:43 AM rudra1in <ru...@gmail.com> wrote:

> HI All,
> I fixed it, there is mismatch in queue name.
> Please help me why fie threads are firing send message?
>
> Thanks in advance,
> RUdra
>
>
>
> --
> Sent from:
> http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
>
>

Re: ActiveMQ artemis listener not working

Posted by rudra1in <ru...@gmail.com>.
HI All,
I fixed it, there is mismatch in queue name.
Please help me why fie threads are firing send message?

Thanks in advance,
RUdra



--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Re: ActiveMQ artemis listener not working

Posted by rudra1in <ru...@gmail.com>.
Thanks for the response, but this is synchronous and I am looking for
synchronous implementation.

Thanks in advance,
Rudra



--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Re: ActiveMQ artemis listener not working

Posted by brusdev <br...@gmail.com>.
Hi,

there is an ActiveMQ Artemis Spring Boot Example at
https://github.com/apache/activemq-artemis/tree/master/examples/features/standard/spring-boot-integration

Regards,
Domenico



--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Re: OutOfMemory Error

Posted by Pavel Molchanov <pa...@infodesk.com>.
Hi,

Seems that I have sent a reply with my full credentials :)

I am authorized to ask these questions in this group. Please ignore
the disclaimer for this specific issue.

Pavel

On Thu, Apr 16, 2020 at 2:33 PM Pavel Molchanov <
pavel.molchanov@infodesk.com> wrote:

> Hi,
>
> We are using 2.11 version.
>
> We are passing around 20 messages/second.
>
> Large messages are usually XML files and images.
>
> Some images are very big, up to 120Mb.
>
> *Pavel Molchanov*
> Director of Software Development
> InfoDesk
> www.infodesk.com
>
> 1 Bridge Street  | Suite 105 | Irvington | New York | 10551
> <https://maps.google.com/?q=660+White+Plains+Road+%7C+Suite+300+%7C+Tarrytown+%7C+New+York+%7C+10591&entry=gmail&source=g>|
> Office: +1 (914) 332-5940
> Change Privacy Settings <https://www.infodesk.com/unsubscription-options>
>  | Contact Privacy Team <un...@infodesk.com> | Privacy Policy
> <https://www.infodesk.com/privacy-policy>
>
> This e-mail message may contain confidential or legally privileged
> information and is intended only for the use of the intended recipient(s).
> Any unauthorized disclosure, dissemination, distribution, copying or the
> taking of any action in reliance on the information herein is prohibited.
>
>
> On Thu, Apr 16, 2020 at 1:34 PM Francesco Nigro <ni...@gmail.com>
> wrote:
>
>> Which version of Artemis and which protocol is used for these large
>> messages? And how much large and how many?
>> Need some more information too help (broker configurations possibly too)
>> :)
>>
>>
>> Il gio 16 apr 2020, 19:05 Pavel Molchanov <pa...@infodesk.com>
>> ha
>> scritto:
>>
>> > Hi,
>> >
>> > We have a cluster of 2 master and 2 slaves Artemis servers.
>> >
>> > Master1 and Slave2 live on one server.
>> > Master2 and Slave1 live on another.
>> >
>> > We have a lot of large messages as well.
>> >
>> > Periodically we get OOE in TCP connection, see screenshot below:
>> >
>> > [image: image.png]
>> > What may be a reason for this? The connection is reading 1.6G. Is it too
>> > much?
>> >
>> > Pavel
>> >
>>
>

Re: OutOfMemory Error

Posted by Pavel Molchanov <pa...@infodesk.com>.
Hi,

We are using 2.11 version.

We are passing around 20 messages/second.

Large messages are usually XML files and images.

Some images are very big, up to 120Mb.

*Pavel Molchanov*
Director of Software Development
InfoDesk
www.infodesk.com

1 Bridge Street  | Suite 105 | Irvington | New York | 10551
<https://maps.google.com/?q=660+White+Plains+Road+%7C+Suite+300+%7C+Tarrytown+%7C+New+York+%7C+10591&entry=gmail&source=g>|
Office: +1 (914) 332-5940
Change Privacy Settings
<https://www.infodesk.com/unsubscription-options> | Contact
Privacy Team <un...@infodesk.com> | Privacy Policy
<https://www.infodesk.com/privacy-policy>

This e-mail message may contain confidential or legally privileged
information and is intended only for the use of the intended recipient(s).
Any unauthorized disclosure, dissemination, distribution, copying or the
taking of any action in reliance on the information herein is prohibited.


On Thu, Apr 16, 2020 at 1:34 PM Francesco Nigro <ni...@gmail.com> wrote:

> Which version of Artemis and which protocol is used for these large
> messages? And how much large and how many?
> Need some more information too help (broker configurations possibly too) :)
>
>
> Il gio 16 apr 2020, 19:05 Pavel Molchanov <pa...@infodesk.com>
> ha
> scritto:
>
> > Hi,
> >
> > We have a cluster of 2 master and 2 slaves Artemis servers.
> >
> > Master1 and Slave2 live on one server.
> > Master2 and Slave1 live on another.
> >
> > We have a lot of large messages as well.
> >
> > Periodically we get OOE in TCP connection, see screenshot below:
> >
> > [image: image.png]
> > What may be a reason for this? The connection is reading 1.6G. Is it too
> > much?
> >
> > Pavel
> >
>

Re: OutOfMemory Error

Posted by Francesco Nigro <ni...@gmail.com>.
Which version of Artemis and which protocol is used for these large
messages? And how much large and how many?
Need some more information too help (broker configurations possibly too) :)


Il gio 16 apr 2020, 19:05 Pavel Molchanov <pa...@infodesk.com> ha
scritto:

> Hi,
>
> We have a cluster of 2 master and 2 slaves Artemis servers.
>
> Master1 and Slave2 live on one server.
> Master2 and Slave1 live on another.
>
> We have a lot of large messages as well.
>
> Periodically we get OOE in TCP connection, see screenshot below:
>
> [image: image.png]
> What may be a reason for this? The connection is reading 1.6G. Is it too
> much?
>
> Pavel
>

OutOfMemory Error

Posted by Pavel Molchanov <pa...@infodesk.com>.
Hi,

We have a cluster of 2 master and 2 slaves Artemis servers.

Master1 and Slave2 live on one server.
Master2 and Slave1 live on another.

We have a lot of large messages as well.

Periodically we get OOE in TCP connection, see screenshot below:

[image: image.png]
What may be a reason for this? The connection is reading 1.6G. Is it too
much?

Pavel