diff options
Diffstat (limited to 'qpid/tools/src/java')
| -rw-r--r-- | qpid/tools/src/java/qpid-qmf2-tools/src/main/java/org/apache/qpid/qmf2/tools/QpidConfig.java | 18 |
1 files changed, 0 insertions, 18 deletions
diff --git a/qpid/tools/src/java/qpid-qmf2-tools/src/main/java/org/apache/qpid/qmf2/tools/QpidConfig.java b/qpid/tools/src/java/qpid-qmf2-tools/src/main/java/org/apache/qpid/qmf2/tools/QpidConfig.java index 04a0642e2e..8cca763e4c 100644 --- a/qpid/tools/src/java/qpid-qmf2-tools/src/main/java/org/apache/qpid/qmf2/tools/QpidConfig.java +++ b/qpid/tools/src/java/qpid-qmf2-tools/src/main/java/org/apache/qpid/qmf2/tools/QpidConfig.java @@ -344,7 +344,6 @@ public final class QpidConfig private String _order = "fifo"; private boolean _msgSequence = false; private boolean _ive = false; - private long _eventGeneration = 0; private String _file = null; // New to Qpid 0.10 qpid-config @@ -364,7 +363,6 @@ public final class QpidConfig private static final String LVQNB = "qpid.last_value_queue_no_browse"; private static final String MSG_SEQUENCE = "qpid.msg_sequence"; private static final String IVE = "qpid.ive"; - private static final String QUEUE_EVENT_GENERATION = "qpid.queue_event_generation"; private static final String FLOW_STOP_COUNT = "qpid.flow_stop_count"; private static final String FLOW_RESUME_COUNT = "qpid.flow_resume_count"; private static final String FLOW_STOP_SIZE = "qpid.flow_stop_size"; @@ -387,7 +385,6 @@ public final class QpidConfig SPECIAL_ARGS.add(LVQNB); SPECIAL_ARGS.add(MSG_SEQUENCE); SPECIAL_ARGS.add(IVE); - SPECIAL_ARGS.add(QUEUE_EVENT_GENERATION); SPECIAL_ARGS.add(FLOW_STOP_COUNT); SPECIAL_ARGS.add(FLOW_RESUME_COUNT); SPECIAL_ARGS.add(FLOW_STOP_SIZE); @@ -714,11 +711,6 @@ for (Map.Entry<String, Object> entry : args.entrySet()) { System.out.printf("--order lvq-no-browse "); } - if (args.containsKey(QUEUE_EVENT_GENERATION)) - { - System.out.printf("--generate-queue-events=%d ", QmfData.getLong(args.get(QUEUE_EVENT_GENERATION))); - } - if (queue.hasValue("altExchange")) { ObjectId altExchangeRef = queue.getRefValue("altExchange"); @@ -936,11 +928,6 @@ for (Map.Entry<String, Object> entry : args.entrySet()) { properties.put(LVQNB, 1l); } - if (_eventGeneration > 0) - { - properties.put(QUEUE_EVENT_GENERATION, _eventGeneration); - } - if (_altExchange != null) { properties.put("alternate-exchange", _altExchange); @@ -1393,11 +1380,6 @@ for (Map.Entry<String, Object> entry : args.entrySet()) { _ive = true; } - if (opt[0].equals("--generate-queue-events")) - { - _eventGeneration = Long.parseLong(opt[1]); - } - if (opt[0].equals("--force")) { _ifEmpty = false; |