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);
            }
        }
    }
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.
/ * Set this broker object to receive messages during a given period of time blocking execution .