vineyard-commbroker/src/main/java/com/hi3project/vineyard/comm/broker/AsyncMessageBroker.java
public synchronized void receiveMessagesSyncronously(long ms) throws ServiceGroundingException
    {
        for (IChannelConsumer chConsumer : this.serviceChannelConsumers)
        {
            if (chConsumer instanceof AbstractJMSChannelConsumer)
            {
                AbstractJMSChannelConsumer achConsumer = (AbstractJMSChannelConsumer) chConsumer;
                achConsumer.receiveOrWait(ms);
            }
            if (chConsumer instanceof AbstractStompChannelConsumer)
            {
                AbstractStompChannelConsumer achConsumer = (AbstractStompChannelConsumer) chConsumer;
                achConsumer.receiveOrWait(ms);
            }
        }
    }
public synchronized void receiveMessagesSyncronously(long ms) throws ServiceGroundingException
    {
        for (IChannelConsumer chConsumer : this.serviceChannelConsumers)
        {
            if (chConsumer instanceof AbstractJMSChannelConsumer)
            {
                AbstractJMSChannelConsumer achConsumer = (AbstractJMSChannelConsumer) chConsumer;
                achConsumer.receiveOrWait(ms);
            }
            if (chConsumer instanceof AbstractStompChannelConsumer)
            {
                AbstractStompChannelConsumer achConsumer = (AbstractStompChannelConsumer) chConsumer;
                achConsumer.receiveOrWait(ms);
            }
        }
    }
/*
Set this broker object to receive messages during a given period of time, blocking execution.