Examples of ProcessQueue

Examples of com.alibaba.rocketmq.client.impl.consumer.ProcessQueue

1114
1115
1116
1117
1118
1119
1120
1121
1122
1123
1124
1125
1126
                    consumer.getRebalanceImpl().getProcessQueueTable();
            Iterator<MessageQueue> itr = processQueueTable.keySet().iterator();
            while (itr.hasNext()) {
                MessageQueue mq = itr.next();
                if (topic.equals(mq.getTopic())) {
                    ProcessQueue pq = processQueueTable.get(mq);
                    pq.setDroped(true);
                    pq.clear();
                }
            }

            // 更新消费队列的 offset 并提交到 broker
            Iterator<MessageQueue> iterator = offsetTable.keySet().iterator();
View Full Code Here

Examples of com.alibaba.rocketmq.client.impl.consumer.ProcessQueue

1115
1116
1117
1118
1119
1120
1121
1122
1123
1124
1125
1126
1127
                    consumer.getRebalanceImpl().getProcessQueueTable();
            Iterator<MessageQueue> itr = processQueueTable.keySet().iterator();
            while (itr.hasNext()) {
                MessageQueue mq = itr.next();
                if (topic.equals(mq.getTopic())) {
                    ProcessQueue pq = processQueueTable.get(mq);
                    pq.setDroped(true);
                    pq.clear();
                }
            }

            // 更新消费队列的 offset 并提交到 broker
            Iterator<MessageQueue> iterator = offsetTable.keySet().iterator();
View Full Code Here

Examples of com.alibaba.rocketmq.client.impl.consumer.ProcessQueue

1219
1220
1221
1222
1223
1224
1225
1226
1227
1228
1229
1230
1231
                    consumer.getRebalanceImpl().getProcessQueueTable();
            Iterator<MessageQueue> itr = processQueueTable.keySet().iterator();
            while (itr.hasNext()) {
                MessageQueue mq = itr.next();
                if (topic.equals(mq.getTopic())) {
                    ProcessQueue pq = processQueueTable.get(mq);
                    pq.setDroped(true);
                    pq.clear();
                }
            }

            // 更新消费队列的 offset 并提交到 broker
            Iterator<MessageQueue> iterator = offsetTable.keySet().iterator();
View Full Code Here

Examples of com.alibaba.rocketmq.client.impl.consumer.ProcessQueue

1199
1200
1201
1202
1203
1204
1205
1206
1207
1208
1209
1210
1211
                    consumer.getRebalanceImpl().getProcessQueueTable();
            Iterator<MessageQueue> itr = processQueueTable.keySet().iterator();
            while (itr.hasNext()) {
                MessageQueue mq = itr.next();
                if (topic.equals(mq.getTopic())) {
                    ProcessQueue pq = processQueueTable.get(mq);
                    pq.setDroped(true);
                    pq.clear();
                }
            }

            // 更新消费队列的 offset 并提交到 broker
            Iterator<MessageQueue> iterator = offsetTable.keySet().iterator();
View Full Code Here

Examples of com.alibaba.rocketmq.client.impl.consumer.ProcessQueue

1213
1214
1215
1216
1217
1218
1219
1220
1221
1222
1223
1224
1225
                    consumer.getRebalanceImpl().getProcessQueueTable();
            Iterator<MessageQueue> itr = processQueueTable.keySet().iterator();
            while (itr.hasNext()) {
                MessageQueue mq = itr.next();
                if (topic.equals(mq.getTopic())) {
                    ProcessQueue pq = processQueueTable.get(mq);
                    pq.setDroped(true);
                    pq.clear();
                }
            }

            // 更新消费队列的 offset 并提交到 broker
            Iterator<MessageQueue> iterator = offsetTable.keySet().iterator();
View Full Code Here

Examples of com.alibaba.rocketmq.client.impl.consumer.ProcessQueue

1187
1188
1189
1190
1191
1192
1193
1194
1195
1196
1197
1198
1199
                    consumer.getRebalanceImpl().getProcessQueueTable();
            Iterator<MessageQueue> itr = processQueueTable.keySet().iterator();
            while (itr.hasNext()) {
                MessageQueue mq = itr.next();
                if (topic.equals(mq.getTopic())) {
                    ProcessQueue pq = processQueueTable.get(mq);
                    pq.setDroped(true);
                    pq.clear();
                }
            }

            // 更新消费队列的 offset 并提交到 broker
            Iterator<MessageQueue> iterator = offsetTable.keySet().iterator();
View Full Code Here

Examples of com.alibaba.rocketmq.client.impl.consumer.ProcessQueue

1145
1146
1147
1148
1149
1150
1151
1152
1153
1154
1155
1156
1157
                    consumer.getRebalanceImpl().getProcessQueueTable();
            Iterator<MessageQueue> itr = processQueueTable.keySet().iterator();
            while (itr.hasNext()) {
                MessageQueue mq = itr.next();
                if (topic.equals(mq.getTopic())) {
                    ProcessQueue pq = processQueueTable.get(mq);
                    pq.setDroped(true);
                    pq.clear();
                }
            }

            // 更新消费队列的 offset 并提交到 broker
            Iterator<MessageQueue> iterator = offsetTable.keySet().iterator();
View Full Code Here

Examples of pl.net.bluesoft.rnd.processtool.model.nonpersistent.ProcessQueue

90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
      @Override
      public void buttonClick(ClickEvent event) {
        if (table.getValue() == null)
          return;
       
        ProcessQueue pq = (ProcessQueue)table.getValue();
        if (pq.getUserAdded() == null || pq.getUserAdded() == false) {
          getWindow().showNotification(getMessage("queues.remove.forbidden"));
          return;
        }
       
        final Collection<ProcessQueueConfig> queues = new ArrayList<ProcessQueueConfig>();
        ProcessQueueConfig config = new ProcessQueueConfig();
        config.setName(pq.getName());
        queues.add(config);
       
        withErrorHandling(getApplication(), new Runnable() {

          @Override
View Full Code Here

Examples of pl.net.bluesoft.rnd.processtool.model.nonpersistent.ProcessQueue

157
158
159
160
161
162
163
164
165
166
167
168
    });

        table.addGeneratedColumn("translation", new ColumnGenerator() {
            @Override
            public Object generateCell(Table source, Object itemId, Object columnId) {
                ProcessQueue queue = (ProcessQueue) itemId;
                String translation = getMessage(queue.getDescription());
                return translation != null ? translation : "";
            }
        });
   
    table.setVisibleColumns(new Object[] { "description", "translation", "processCount", "name", "browsable", "userAdded" });
View Full Code Here

Examples of pl.net.bluesoft.rnd.processtool.model.nonpersistent.ProcessQueue

204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
    viewController.addView(new ComponentPaneRenderer<QueueListPane>(new QueueListPane(this))
    {
      @Override
      public Component render(Map<String,?> viewData)
      {
        ProcessQueue q = (ProcessQueue)viewData.get("queue");
        ProcessInstanceFilter filter = (ProcessInstanceFilter)viewData.get("filter");
        pane.setFilter(filter);
        pane.setQueue(q);
        leftPanelTrigger.show();
        return pane.init();
      }
    });

    viewController.addView(new ComponentPaneRenderer<OtherUserQueueListPane>(new OtherUserQueueListPane(this))
    {
      @Override
      public Component render(Map<String,?> viewData)
      {
        ProcessQueue queue = (ProcessQueue)viewData.get("queue");
        UserData user = (UserData)viewData.get("user");
        ProcessInstanceFilter filter = (ProcessInstanceFilter)viewData.get("filter");
        pane.setFilter(filter);
        pane.setUserData(user);
        pane.setQueue(queue);
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.