The AMQP drivers executes an AMQP command within a certain amount of time (i.e. ConnectionFactory.DEFAULT_CHANNEL_RPC_TIMEOUT). Op-rabbit should allow the op-rabbit user to set this timeout according to his needs. In order to achieve this com.spingo.op_rabbit.ConnectionParams should expose it in the last parameter of the constructor:
channelRpcTimeout: Int = ConnectionFactory.DEFAULT_CHANNEL_RPC_TIMEOUT
This also ensures backward compatibility.
@timcharper this is branched off rabbitmq-connection-setup-callback which is waiting for merge approval into master.
Problem:
The AMQP drivers executes an AMQP command within a certain amount of time (i.e. ConnectionFactory.DEFAULT_CHANNEL_RPC_TIMEOUT). Op-rabbit should allow the op-rabbit user to set this timeout according to his needs. In order to achieve this
com.spingo.op_rabbit.ConnectionParamsshould expose it in the last parameter of the constructor:channelRpcTimeout: Int = ConnectionFactory.DEFAULT_CHANNEL_RPC_TIMEOUTThis also ensures backward compatibility.
@timcharper this is branched off rabbitmq-connection-setup-callback which is waiting for merge approval into master.