I created a BrokerFilter implementation that gathers some data when messages
are passed around. Now that data I want to send to each new consummer added
if the destination matches some criteria. So after calling
super.addConsumer() i want to build a ActiveMQBytesMessage and send it to
that consumm
A bit of further research:
in org.apache.activemq.openwire.OpenWireFormat.marshal there is:
.
BooleanStream bs = new BooleanStream();
size += dsm.tightMarshal1(this, c, bs);
size += bs.marshalledSize();
if( !sizePref
Can I do this with the ActiveMQ API?
I was thinking maybe using a FilterBroker for that...
--
View this message in context:
http://www.nabble.com/How-can-I-blacklist-some-IP-addresses--tf3725915s2354.html#a10427189
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Sometime in an aplication I develop using ActiveMQ I get an error. It appears
quite "random" and not very often
Here is a stack:
Exception in thread "ActiveMQ Task" java.lang.NullPointerException
at
org.apache.activemq.openwire.v2.BaseDataStreamMarshaller.tightMarshalString2(BaseDataStream
