Matthew Sackman msackman
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| package com.rabbitmq.examples; | |
| import java.io.IOException; | |
| import com.rabbitmq.client.Channel; | |
| import com.rabbitmq.client.Connection; | |
| import com.rabbitmq.client.ConnectionFactory; | |
| import com.rabbitmq.client.ConsumerCancelledException; | |
| import com.rabbitmq.client.QueueingConsumerCoDel.Delivery; | |
| import com.rabbitmq.client.QueueingConsumerCoDel; |
msackman
/ QueueingConsumerCoDel.java
Created
May 11, 2012 10:00
QueueingConsumer extended with the CoDel algorithm
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| // The contents of this file are subject to the Mozilla Public License | |
| // Version 1.1 (the "License"); you may not use this file except in | |
| // compliance with the License. You may obtain a copy of the License | |
| // at http://www.mozilla.org/MPL/ | |
| // | |
| // Software distributed under the License is distributed on an "AS IS" | |
| // basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See | |
| // the License for the specific language governing rights and | |
| // limitations under the License. | |
| // |