Adding logic to queue/dequeue over openwire.