Re: ActiveMQ Duplex Network connector only creating bridge on initiating side

2016-05-12 Thread exabrial 
2 also works actually. 



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/ActiveMQ-Duplex-Network-connector-only-creating-bridge-on-initiating-side-tp4711821p4711860.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Why does having a staticallyIncludedDestination create a consumer?

2016-05-12 Thread exabrial 
Ok, that makes sense then why there are two consumers.

What's strange to me is the message will travel from spoke1->hub->spoke2
even if there are no consumers on spoke2 if I have
staticallyIncludedDestinations set on the spokes. Why is that?



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Why-does-having-a-staticallyIncludedDestination-create-a-consumer-tp4711832p4711861.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

[Artemis, Qpid JMS] Connection limit

2016-05-12 Thread Vavricka 
Hi, 

 I am testing Artemis 1.3.0-SNAPSHOT with Qpid JMS 0.9.0 client.

  I manage to configure restriction for user "user2" by setting below in
broker.xml.

  
  
  5
  
  

  When I try non-ssl connection, server correctly allow only 5 active
connection. When I try to create another connection, server throws exception
in log "Too many sessions for user 'user2'. Sessions allowed: 5.", but
client tries to connect indefinitely. This is correct behavior? Should be
client informed 

Log from client below:

DEBUG io.netty.util.internal.logging.InternalLoggerFactory - Using SLF4J as
the default logging framework
DEBUG io.netty.channel.MultithreadEventLoopGroup -
-Dio.netty.eventLoopThreads: 24
DEBUG io.netty.util.internal.PlatformDependent - UID: 23280
DEBUG io.netty.util.internal.PlatformDependent - Java version: 8
DEBUG io.netty.util.internal.PlatformDependent - -Dio.netty.noUnsafe: false
DEBUG io.netty.util.internal.PlatformDependent0 -
java.nio.ByteBuffer.cleaner: available
DEBUG io.netty.util.internal.PlatformDependent0 - java.nio.Buffer.address:
available
DEBUG io.netty.util.internal.PlatformDependent0 - sun.misc.Unsafe.theUnsafe:
available
DEBUG io.netty.util.internal.PlatformDependent0 -
sun.misc.Unsafe.copyMemory: available
DEBUG io.netty.util.internal.PlatformDependent0 - java.nio.Bits.unaligned:
true
DEBUG io.netty.util.internal.PlatformDependent - sun.misc.Unsafe: available
DEBUG io.netty.util.internal.PlatformDependent - -Dio.netty.noJavassist:
false
DEBUG io.netty.util.internal.PlatformDependent - Javassist: available
DEBUG io.netty.util.internal.PlatformDependent - -Dio.netty.tmpdir: /tmp
(java.io.tmpdir)
DEBUG io.netty.util.internal.PlatformDependent - -Dio.netty.bitMode: 64
(sun.arch.data.model)
DEBUG io.netty.util.internal.PlatformDependent - -Dio.netty.noPreferDirect:
false
DEBUG io.netty.channel.nio.NioEventLoop - -Dio.netty.noKeySetOptimization:
false
DEBUG io.netty.channel.nio.NioEventLoop -
-Dio.netty.selectorAutoRebuildThreshold: 512
TRACE io.netty.channel.nio.NioEventLoop - Instrumented an optimized
java.util.Set into: sun.nio.ch.EPollSelectorImpl@7ee955a8
DEBUG io.netty.buffer.PooledByteBufAllocator -
-Dio.netty.allocator.numHeapArenas: 12
DEBUG io.netty.buffer.PooledByteBufAllocator -
-Dio.netty.allocator.numDirectArenas: 12
DEBUG io.netty.buffer.PooledByteBufAllocator -
-Dio.netty.allocator.pageSize: 8192
DEBUG io.netty.buffer.PooledByteBufAllocator -
-Dio.netty.allocator.maxOrder: 11
DEBUG io.netty.buffer.PooledByteBufAllocator -
-Dio.netty.allocator.chunkSize: 16777216
DEBUG io.netty.util.internal.ThreadLocalRandom -
-Dio.netty.initialSeedUniquifier: 0x1726f4187f064e47
DEBUG io.netty.channel.ChannelOutboundBuffer -
-Dio.netty.threadLocalDirectBufferSize: 65536
DEBUG io.netty.buffer.ByteBufUtil - -Dio.netty.allocator.type: unpooled
DEBUG io.netty.util.internal.JavassistTypeParameterMatcherGenerator -
Generated:
io.netty.util.internal.__matchers__.io.netty.buffer.ByteBufMatcher
TRACE org.apache.qpid.jms.transports.netty.NettyTcpTransport - Channel has
become active! Channel is [id: 0x8abf6d06, /172.16.151.69:52414 =>
cbgc03/172.16.153.12:5674]
TRACE io.netty.channel.nio.NioEventLoop - Instrumented an optimized
java.util.Set into: sun.nio.ch.EPollSelectorImpl@35e2d654
TRACE org.apache.qpid.jms.transports.netty.NettyTcpTransport - Channel has
become active! Channel is [id: 0xae3980a3, /172.16.151.69:52415 =>
cbgc03/172.16.153.12:5674]
TRACE io.netty.channel.nio.NioEventLoop - Instrumented an optimized
java.util.Set into: sun.nio.ch.EPollSelectorImpl@55183b20
TRACE org.apache.qpid.jms.transports.netty.NettyTcpTransport - Channel has
become active! Channel is [id: 0x36f1b554, /172.16.151.69:52416 =>
cbgc03/172.16.153.12:5674]
TRACE io.netty.channel.nio.NioEventLoop - Instrumented an optimized
java.util.Set into: sun.nio.ch.EPollSelectorImpl@6cf0e0ba
TRACE org.apache.qpid.jms.transports.netty.NettyTcpTransport - Channel has
become active! Channel is [id: 0xfb7c10d3, /172.16.151.69:52417 =>
cbgc03/172.16.153.12:5674]
TRACE io.netty.channel.nio.NioEventLoop - Instrumented an optimized
java.util.Set into: sun.nio.ch.EPollSelectorImpl@42a48628
TRACE org.apache.qpid.jms.transports.netty.NettyTcpTransport - Channel has
become active! Channel is [id: 0xc1f332bd, /172.16.151.69:52418 =>
cbgc03/172.16.153.12:5674]
DEBUG io.netty.util.ResourceLeakDetector - -Dio.netty.leakDetectionLevel:
simple
TRACE org.apache.qpid.jms.transports.netty.NettyTcpTransport - Attempted
write of: 8 bytes
TRACE org.apache.qpid.jms.transports.netty.NettyTcpTransport - New data
read: 42 bytes incoming: UnpooledHeapByteBuf(ridx: 0, widx: 42, cap: 65536)
TRACE org.apache.qpid.jms.provider.amqp.AmqpProvider - New Proton Event:
CONNECTION_INIT
TRACE org.apache.qpid.jms.provider.amqp.AmqpProvider - New Proton Event:
CONNECTION_LOCAL_OPEN
INFO org.apache.qpid.jms.sasl.SaslMechanismFinder - Best match for SASL auth
was: SASL-PLAIN
TRACE org.apache.qpid.jms.transports.netty.NettyTcpTransport -

Measuring service time of the broker

2016-05-12 Thread siddutta 
I have a network of brokers and wish to find the avg. time a message stays at
a broker's queue. Is there a plugin or API call that I can make to find
this?



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Measuring-service-time-of-the-broker-tp4711866.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Measuring service time of the broker

2016-05-12 Thread Quinn Stevenson 
Have you looked at the Statistics Plugin? ( 
http://activemq.apache.org/statisticsplugin.html 
 ).  It will give you the 
averageEnqueueTime for each destination.

> On May 12, 2016, at 10:30 AM, siddutta  wrote:
> 
> I have a network of brokers and wish to find the avg. time a message stays at
> a broker's queue. Is there a plugin or API call that I can make to find
> this?
> 
> 
> 
> --
> View this message in context: 
> http://activemq.2283324.n4.nabble.com/Measuring-service-time-of-the-broker-tp4711866.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Why does having a staticallyIncludedDestination create a consumer?

2016-05-12 Thread Tim Bain 
Because that's what staticallyIncludedDestinations does: it forwards
messages when there isn't a consumer on the other end.  By contrast,
dynamicallyIncludedDestinations forwards messages only when there is a
consumer on the other end (i.e. on demand).
On May 12, 2016 8:23 AM, "exabrial"  wrote:

> Ok, that makes sense then why there are two consumers.
>
> What's strange to me is the message will travel from spoke1->hub->spoke2
> even if there are no consumers on spoke2 if I have
> staticallyIncludedDestinations set on the spokes. Why is that?
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/Why-does-having-a-staticallyIncludedDestination-create-a-consumer-tp4711832p4711861.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>