activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Axel Podehl (JIRA)" <j...@apache.org>
Subject [jira] [Closed] (AMQ-4626) AMQP broker prints producer's connection id to stdout
Date Mon, 15 Jul 2013 12:56:49 GMT

     [ https://issues.apache.org/jira/browse/AMQ-4626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Axel Podehl closed AMQ-4626.
----------------------------

       Resolution: Fixed
    Fix Version/s: 5.9.0

don't see this anymore with the latest 5.9 snapshot from 20130711
Thanks.
                
> AMQP broker prints producer's connection id to stdout
> -----------------------------------------------------
>
>                 Key: AMQ-4626
>                 URL: https://issues.apache.org/jira/browse/AMQ-4626
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Broker
>    Affects Versions: 5.9.0
>         Environment: Windows 7
>            Reporter: Axel Podehl
>            Priority: Minor
>             Fix For: 5.9.0
>
>
> Hi,
> I'm using an AMQP transport connector in an embedded Broker, but whenever a producer
is connecting the connection id appears on standard out. Probably some left-over of some debugging
code ?
> I tested also with the latest 5.9.0 snapshot from 7/9/2013 and it's still there.
> My code is something like this:
>           String amqpURI = "amqp://0.0.0.0:" + amqpPort + "?maximumConnections=1000&amp;wireformat.maxFrameSize=104857600";
>         
>           logInfo("ActiveMQ: adding AMQP transport: " + amqpURI );
>           
>           TransportConnector amqpConnector = new TransportConnector();
>           amqpConnector.setName("amqp");
>           amqpConnector.setUri( new URI(amqpURI) );
>           activeMqBroker.addConnector(amqpConnector);
> and once a QPID amqp_1_0 producer connects, I see this (added newlines for clarity):
> 7924 [ActiveMQ BrokerService[localhost] Task-2] DEBUG org.apache.activemq.broker.region.Queue
 - TEST toPageIn: 11, Inflight: 0, pagedInMessages.size 0, enqueueCount: 10, dequeueCount:
0
> ID:Berlin-60845-1373442523293-2:1:0
> ----------- full trace (with some of my own logs in between):
> Starting ActiveMQ Broker, see C:\CodeStreet\ReplayServiceJMS\bin\log\channel-jni.log
> 0 [main] INFO ChannelJNI  - ### Starting ActiveMQ broker with broker url: broker:(tcp://localhost:51515)?useJmx=true
and parameters: persistent=true,memory=64mb,store=1GB,temp=100mb,amqpPort=5672
> 171 [main] INFO org.apache.activemq.store.kahadb.plist.PListStoreImpl  - PListStore:[C:\CodeStreet\ReplayServiceJMS\bin\activemq-data\localhost\tmp_storage]
started
> 179 [main] INFO ChannelJNI  - ActiveMQ: adding AMQP transport: amqp://0.0.0.0:5672?maximumConnections=1000&amp;wireformat.maxFrameSize=104857600
> 179 [main] INFO ChannelJNI  - network connectors: []
> 179 [main] INFO ChannelJNI  - transport connectors: [tcp://127.0.0.1:51515, amqp]
> 225 [main] DEBUG org.apache.activemq.broker.jmx.ManagementContext  - Creating RMIRegistry
on port 1099
> 258 [main] DEBUG org.apache.activemq.broker.jmx.ManagementContext  - Probably not using
JRE 1.4: mx4j.tools.naming.NamingService
> 261 [main] DEBUG org.apache.activemq.broker.jmx.ManagementContext  - Created JMXConnectorServer
javax.management.remote.rmi.RMIConnectorServer@4979935d
> 262 [JMX connector] DEBUG org.apache.activemq.broker.jmx.ManagementContext  - Starting
JMXConnectorServer...
> 335 [main] INFO org.apache.activemq.broker.BrokerService  - Using Persistence Adapter:
KahaDBPersistenceAdapter[C:\CodeStreet\ReplayServiceJMS\bin\activemq-data\localhost\KahaDB]
> 336 [JMX connector] INFO org.apache.activemq.broker.jmx.ManagementContext  - JMX consoles
can connect to service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi
> 690 [main] DEBUG org.apache.activemq.store.kahadb.disk.page.PageFile  - Page File: activemq-data\localhost\KahaDB\db.data,
Recovering page file...
> 700 [main] INFO org.apache.activemq.store.kahadb.MessageDatabase  - KahaDB is version
4
> 701 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 706 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 706 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 706 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 707 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 707 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 707 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 707 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 707 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 707 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 707 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 708 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 708 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 709 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.ListIndex  - loading
> 711 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 711 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 711 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 712 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 712 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 712 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 712 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 712 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.ListIndex  - loading
> 712 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 712 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 712 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 712 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 712 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 712 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 712 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 712 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.ListIndex  - loading
> 713 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 713 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 713 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 713 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 713 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 713 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 713 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 713 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.ListIndex  - loading
> 713 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 713 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 713 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 714 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 714 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 714 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 714 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 714 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.ListIndex  - loading
> 714 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 714 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 714 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 714 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 714 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 714 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 714 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 715 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.ListIndex  - loading
> 715 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 715 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 715 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 715 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 715 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 715 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 715 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.BTreeIndex  - loading
> 715 [main] DEBUG org.apache.activemq.store.kahadb.disk.index.ListIndex  - loading
> 730 [main] INFO org.apache.activemq.store.kahadb.MessageDatabase  - Recovering from the
journal ...
> 740 [main] INFO org.apache.activemq.store.kahadb.MessageDatabase  - Recovery replayed
23 operations from the journal in 0.024 seconds.
> 929 [main] INFO org.apache.activemq.broker.BrokerService  - Apache ActiveMQ 5.8.0 (localhost,
ID:Berlin-60845-1373442523293-0:1) is starting
> 934 [main] DEBUG org.apache.activemq.broker.region.AbstractRegion  - localhost adding
destination: queue://TEST
> 957 [main] DEBUG org.apache.activemq.thread.TaskRunnerFactory  - Initialized TaskRunnerFactory[ActiveMQ
BrokerService[localhost] Task] using ExecutorService: java.util.concurrent.ThreadPoolExecutor@26a3960
> 993 [main] DEBUG org.apache.activemq.broker.region.Queue  - TEST toPageIn: 1, Inflight:
0, pagedInMessages.size 0, enqueueCount: 0, dequeueCount: 0
> 1003 [main] DEBUG org.apache.activemq.broker.region.Queue  - TEST toPageIn: 1, Inflight:
0, pagedInMessages.size 0, enqueueCount: 0, dequeueCount: 0
> 1007 [main] DEBUG org.apache.activemq.broker.TransportConnector  - Publishing: tcp://127.0.0.1:51515
for broker transport URI: tcp://127.0.0.1:51515
> 1007 [main] DEBUG org.apache.activemq.broker.TransportConnector  - Publishing: amqp://0.0.0.0:5672
for broker transport URI: amqp://0.0.0.0:5672?maximumConnections=1000&amp;wireformat.maxFrameSize=104857600
> 1008 [main] INFO org.apache.activemq.transport.TransportServerThreadSupport  - Listening
for connections at: tcp://127.0.0.1:51515
> 1009 [main] INFO org.apache.activemq.broker.TransportConnector  - Connector tcp://127.0.0.1:51515
Started
> 1015 [main] INFO org.apache.activemq.transport.TransportServerThreadSupport  - Listening
for connections at: amqp://Berlin:5672?maximumConnections=1000&amp;wireformat.maxFrameSize=104857600
> 1015 [main] INFO org.apache.activemq.broker.TransportConnector  - Connector amqp Started
> 1017 [main] INFO org.apache.activemq.broker.BrokerService  - Apache ActiveMQ 5.8.0 (localhost,
ID:Berlin-60845-1373442523293-0:1) started
> 1017 [main] INFO org.apache.activemq.broker.BrokerService  - For help or more information
please see: http://activemq.apache.org
> 1020 [main] DEBUG org.apache.activemq.broker.region.AbstractRegion  - localhost adding
destination: topic://ActiveMQ.Advisory.MasterBroker
> 1039 [main] INFO ChannelJNI  - ActiveMQ Broker Version: 5.8.0
> 1039 [main] INFO ChannelJNI  - ActiveMQ memory limit: 67108864
> 1039 [main] INFO ChannelJNI  - ActiveMQ memory percent used: 0
> 1039 [main] INFO ChannelJNI  - ActiveMQ persistent: true
> 1039 [main] INFO ChannelJNI  - ActiveMQ sendFailIfNoSpace: false
> 1039 [main] INFO ChannelJNI  - ActiveMQ memory: Usage(Main:memory) percentUsage=0%, usage=0,
limit=67108864, percentUsageMinDelta=1%
> 1039 [main] INFO ChannelJNI  - ActiveMQ store: Usage(Main:store) percentUsage=0%, usage=265900,
limit=1073741824, percentUsageMinDelta=1%
> 1039 [main] INFO ChannelJNI  - ActiveMQ data directory: activemq-data
> 1039 [main] INFO ChannelJNI  - ActiveMQ temp: Usage(Main:temp) percentUsage=0%, usage=0,
limit=104857600, percentUsageMinDelta=1%
> 1039 [main] INFO ChannelJNI  - ActiveMQ temp directory: activemq-data\localhost\tmp_storage
> started
> 5717 [ActiveMQ Journal Checkpoint Worker] DEBUG org.apache.activemq.store.kahadb.MessageDatabase
 - Checkpoint started.
> 5718 [ActiveMQ Journal Checkpoint Worker] DEBUG org.apache.activemq.store.kahadb.MessageDatabase
 - Checkpoint done.
> 7803 [ActiveMQ Transport: tcp:///127.0.0.1:60846@5672] DEBUG org.apache.activemq.broker.TransportConnection
 - Setting up new connection id: ID:Berlin-60845-1373442523293-2:1, address: tcp://127.0.0.1:60846,
info: ConnectionInfo {commandId = 0, responseRequired = true, connectionId = ID:Berlin-60845-1373442523293-2:1,
clientId = TEST, clientIp = null, userName = guest, password = *****, brokerPath = null, brokerMasterConnector
= false, manageable = false, clientMaster = true, faultTolerant = false, failoverReconnect
= false}
> 7803 [ActiveMQ Transport: tcp:///127.0.0.1:60846@5672] DEBUG org.apache.activemq.broker.region.AbstractRegion
 - localhost adding destination: topic://ActiveMQ.Advisory.Connection
> 7877 [ActiveMQ Transport: tcp:///127.0.0.1:60846@5672] DEBUG org.apache.activemq.broker.region.AbstractRegion
 - localhost adding destination: topic://ActiveMQ.Advisory.Producer.Queue.TEST
> 7906 [ActiveMQ Transport: tcp:///127.0.0.1:60846@5672] DEBUG org.apache.activemq.broker.region.Queue
 - localhost Message 0e7fc3d7-de11-4354-89a7-5773edaa9ba5 sent to queue://TEST
> 7906 [ActiveMQ BrokerService[localhost] Task-2] DEBUG org.apache.activemq.broker.region.Queue
 - TEST toPageIn: 2, Inflight: 0, pagedInMessages.size 0, enqueueCount: 1, dequeueCount: 0
> 7909 [ActiveMQ Transport: tcp:///127.0.0.1:60846@5672] DEBUG org.apache.activemq.broker.region.Queue
 - localhost Message d0938476-d96c-4995-a8f9-14fdfc799ab6 sent to queue://TEST
> 7909 [ActiveMQ BrokerService[localhost] Task-2] DEBUG org.apache.activemq.broker.region.Queue
 - TEST toPageIn: 3, Inflight: 0, pagedInMessages.size 0, enqueueCount: 2, dequeueCount: 0
> 7911 [ActiveMQ Transport: tcp:///127.0.0.1:60846@5672] DEBUG org.apache.activemq.broker.region.Queue
 - localhost Message 7af96bbf-8ced-46db-bac3-0f7caf1f3dff sent to queue://TEST
> 7911 [ActiveMQ BrokerService[localhost] Task-2] DEBUG org.apache.activemq.broker.region.Queue
 - TEST toPageIn: 4, Inflight: 0, pagedInMessages.size 0, enqueueCount: 3, dequeueCount: 0
> 7912 [ActiveMQ Transport: tcp:///127.0.0.1:60846@5672] DEBUG org.apache.activemq.broker.region.Queue
 - localhost Message 6d99ab81-3692-452f-9f37-c867b4b0e9d2 sent to queue://TEST
> 7913 [ActiveMQ BrokerService[localhost] Task-2] DEBUG org.apache.activemq.broker.region.Queue
 - TEST toPageIn: 5, Inflight: 0, pagedInMessages.size 0, enqueueCount: 4, dequeueCount: 0
> 7914 [ActiveMQ Transport: tcp:///127.0.0.1:60846@5672] DEBUG org.apache.activemq.broker.region.Queue
 - localhost Message 9065af75-3067-4562-a2c9-23dc23860408 sent to queue://TEST
> 7914 [ActiveMQ BrokerService[localhost] Task-2] DEBUG org.apache.activemq.broker.region.Queue
 - TEST toPageIn: 6, Inflight: 0, pagedInMessages.size 0, enqueueCount: 5, dequeueCount: 0
> 7916 [ActiveMQ Transport: tcp:///127.0.0.1:60846@5672] DEBUG org.apache.activemq.broker.region.Queue
 - localhost Message ac144f32-9355-4662-adb9-5cd16b86e6d0 sent to queue://TEST
> 7916 [ActiveMQ BrokerService[localhost] Task-2] DEBUG org.apache.activemq.broker.region.Queue
 - TEST toPageIn: 7, Inflight: 0, pagedInMessages.size 0, enqueueCount: 6, dequeueCount: 0
> 7918 [ActiveMQ Transport: tcp:///127.0.0.1:60846@5672] DEBUG org.apache.activemq.broker.region.Queue
 - localhost Message dfd673af-7553-4967-a98f-90aebb98e2af sent to queue://TEST
> 7918 [ActiveMQ BrokerService[localhost] Task-2] DEBUG org.apache.activemq.broker.region.Queue
 - TEST toPageIn: 8, Inflight: 0, pagedInMessages.size 0, enqueueCount: 7, dequeueCount: 0
> 7920 [ActiveMQ Transport: tcp:///127.0.0.1:60846@5672] DEBUG org.apache.activemq.broker.region.Queue
 - localhost Message 5677d1bf-4a7b-4dba-8378-f36c2d2f4bfb sent to queue://TEST
> 7921 [ActiveMQ BrokerService[localhost] Task-2] DEBUG org.apache.activemq.broker.region.Queue
 - TEST toPageIn: 9, Inflight: 0, pagedInMessages.size 0, enqueueCount: 8, dequeueCount: 0
> 7922 [ActiveMQ Transport: tcp:///127.0.0.1:60846@5672] DEBUG org.apache.activemq.broker.region.Queue
 - localhost Message cc82e930-1c8a-43ce-8990-1e697b8aebf2 sent to queue://TEST
> 7923 [ActiveMQ BrokerService[localhost] Task-2] DEBUG org.apache.activemq.broker.region.Queue
 - TEST toPageIn: 10, Inflight: 0, pagedInMessages.size 0, enqueueCount: 9, dequeueCount:
0
> 7924 [ActiveMQ Transport: tcp:///127.0.0.1:60846@5672] DEBUG org.apache.activemq.broker.region.Queue
 - localhost Message 306ef2f4-78f1-4842-a17d-1e43a73ea1c1 sent to queue://TEST
> 7924 [ActiveMQ BrokerService[localhost] Task-2] DEBUG org.apache.activemq.broker.region.Queue
 - TEST toPageIn: 11, Inflight: 0, pagedInMessages.size 0, enqueueCount: 10, dequeueCount:
0
> ID:Berlin-60845-1373442523293-2:1:0
> 7928 [ActiveMQ Transport: tcp:///127.0.0.1:60846@5672] DEBUG org.apache.activemq.broker.jmx.ManagementContext
 - Unregistering MBean org.apache.activemq:type=Broker,brokerName=localhost,destinationType=Queue,destinationName=TEST,endpoint=Producer,clientId=TEST,producerId=ID_Berlin-60845-1373442523293-2_1_0_0
> 7929 [ActiveMQ Transport: tcp:///127.0.0.1:60846@5672] DEBUG org.apache.activemq.broker.TransportConnection
 - remove connection id: ID:Berlin-60845-1373442523293-2:1
> 7929 [ActiveMQ Transport: tcp:///127.0.0.1:60846@5672] DEBUG org.apache.activemq.transport.tcp.TcpTransport
 - Stopping transport tcp:///127.0.0.1:60846@5672

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira

Mime
View raw message