activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sk92129 <sk92...@gmail.com>
Subject Re: Test harness to verify Message Order Preservation
Date Wed, 22 Aug 2012 00:29:26 GMT
So far I have tried to put a wait(2000) in the preProcessDispatch:

        @Override
	public void preProcessDispatch(MessageDispatch messageDispatch) {
		String contentStr = new
String(messageDispatch.getMessage().getContent().getData());
		if (pauseThisMsg(contentStr)){
			try {
				messageDispatch.wait(TIMEOUT);
			} catch (InterruptedException e) {
				LOGGER.info("preProcessDispatch wait interrupted.");
			}
		}
		
		super.preProcessDispatch(messageDispatch);
	}

This caused all the messages that should have come later, to not appear at
all on the consumer side.






--
View this message in context: http://activemq.2283324.n4.nabble.com/Test-harness-to-verify-Message-Order-Preservation-tp4655158p4655406.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Mime
View raw message