本文整理汇总了Java中org.apache.activemq.command.ActiveMQMapMessage类的典型用法代码示例。如果您正苦于以下问题:Java ActiveMQMapMessage类的具体用法?Java ActiveMQMapMessage怎么用?Java ActiveMQMapMessage使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
ActiveMQMapMessage类属于org.apache.activemq.command包,在下文中一共展示了ActiveMQMapMessage类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: prepareSubscriptionMessage
import org.apache.activemq.command.ActiveMQMapMessage; //导入依赖的package包/类
protected ActiveMQMapMessage prepareSubscriptionMessage(SubscriptionViewMBean subscriber) throws JMSException {
ActiveMQMapMessage statsMessage = new ActiveMQMapMessage();
statsMessage.setString("destinationName", subscriber.getDestinationName());
statsMessage.setString("clientId", subscriber.getClientId());
statsMessage.setString("connectionId", subscriber.getConnectionId());
statsMessage.setLong("sessionId", subscriber.getSessionId());
statsMessage.setString("selector", subscriber.getSelector());
statsMessage.setLong("enqueueCounter", subscriber.getEnqueueCounter());
statsMessage.setLong("dequeueCounter", subscriber.getDequeueCounter());
statsMessage.setLong("dispatchedCounter", subscriber.getDispatchedCounter());
statsMessage.setLong("dispatchedQueueSize", subscriber.getDispatchedQueueSize());
statsMessage.setInt("prefetchSize", subscriber.getPrefetchSize());
statsMessage.setInt("maximumPendingMessageLimit", subscriber.getMaximumPendingMessageLimit());
statsMessage.setBoolean("exclusive", subscriber.isExclusive());
statsMessage.setBoolean("retroactive", subscriber.isRetroactive());
statsMessage.setBoolean("slowConsumer", subscriber.isSlowConsumer());
return statsMessage;
}
开发者ID:DiamondLightSource,项目名称:daq-eclipse,代码行数:19,代码来源:StatisticsBroker.java
示例2: sendStats
import org.apache.activemq.command.ActiveMQMapMessage; //导入依赖的package包/类
protected void sendStats(ConnectionContext context, ActiveMQMapMessage msg, ActiveMQDestination replyTo)
throws Exception {
msg.setPersistent(false);
msg.setType(AdvisorySupport.ADIVSORY_MESSAGE_TYPE);
msg.setMessageId(new MessageId(this.advisoryProducerId, this.messageIdGenerator.getNextSequenceId()));
msg.setDestination(replyTo);
msg.setResponseRequired(false);
msg.setProducerId(this.advisoryProducerId);
boolean originalFlowControl = context.isProducerFlowControl();
final ProducerBrokerExchange producerExchange = new ProducerBrokerExchange();
producerExchange.setConnectionContext(context);
producerExchange.setMutable(true);
producerExchange.setProducerState(new ProducerState(new ProducerInfo()));
try {
context.setProducerFlowControl(false);
this.next.send(producerExchange, msg);
} finally {
context.setProducerFlowControl(originalFlowControl);
}
}
开发者ID:DiamondLightSource,项目名称:daq-eclipse,代码行数:21,代码来源:StatisticsBroker.java
示例3: transformToMap
import org.apache.activemq.command.ActiveMQMapMessage; //导入依赖的package包/类
/**
* Transform an ActiveMQMapMessage to a Map
*
* @param msg - map message to transform
* @return map object
* @throws JMSException
*/
protected Map transformToMap(ActiveMQMapMessage msg) throws JMSException {
Properties props = new Properties();
props.putAll(transformToMap((ActiveMQMessage)msg));
// Get map properties
Enumeration e = msg.getMapNames();
while (e.hasMoreElements()) {
String key = (String)e.nextElement();
Object val = msg.getObject(key);
if (val != null) {
props.setProperty(AmqMessagesUtil.JMS_MESSAGE_BODY_PREFIX + key, getDisplayString(val));
}
}
return props;
}
开发者ID:DiamondLightSource,项目名称:daq-eclipse,代码行数:25,代码来源:MapTransformFilter.java
示例4: testMapMessageCompression
import org.apache.activemq.command.ActiveMQMapMessage; //导入依赖的package包/类
@Test
public void testMapMessageCompression() throws Exception {
MessageConsumer consumer1 = remoteSession.createConsumer(included);
MessageProducer producer = localSession.createProducer(included);
producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
waitForConsumerRegistration(localBroker, 1, included);
MapMessage test = localSession.createMapMessage();
for (int i = 0; i < 100; ++i) {
test.setString(Integer.toString(i), "test string: " + i);
}
producer.send(test);
Message msg = consumer1.receive(RECEIVE_TIMEOUT_MILLS);
assertNotNull(msg);
ActiveMQMapMessage message = (ActiveMQMapMessage) msg;
assertTrue(message.isCompressed());
for (int i = 0; i < 100; ++i) {
assertEquals("test string: " + i, message.getString(Integer.toString(i)));
}
}
开发者ID:apache,项目名称:activemq-artemis,代码行数:26,代码来源:CompressionOverNetworkTest.java
示例5: addScanToQueue
import org.apache.activemq.command.ActiveMQMapMessage; //导入依赖的package包/类
@Override
public void addScanToQueue(String fileName, Integer channelId, Integer orgId, Integer appId,
Calendar calendar, ApplicationChannel applicationChannel) {
String userName = SecurityContextHolder.getContext().getAuthentication().getName();
log.info("User " + userName + " is adding a scan to the queue with the file name " + fileName + ".");
MapMessage scanMap = new ActiveMQMapMessage();
try {
scanMap.setString("userName", userName);
scanMap.setInt("channelId", channelId);
scanMap.setString("fileName", fileName);
scanMap.setString("type", QueueConstants.NORMAL_SCAN_TYPE);
scanMap.setString("urlPath", "/organizations/" + orgId
+ "/applications/" + appId);
scanMap.setString("urlText", "Go to Application");
} catch (JMSException e) {
log.error(jmsErrorString);
e.printStackTrace();
}
sendMap(scanMap, calendar, applicationChannel);
}
开发者ID:jqxin2006,项目名称:threadfixRack,代码行数:25,代码来源:QueueSenderImpl.java
示例6: addDefectTrackerVulnUpdate
import org.apache.activemq.command.ActiveMQMapMessage; //导入依赖的package包/类
@Override
public void addDefectTrackerVulnUpdate(Integer orgId, Integer appId) {
String userName = SecurityContextHolder.getContext().getAuthentication().getName();
log.info("User " + userName + " is adding a defect tracker update for application with ID " + appId + ".");
if (appId == null)
return;
MapMessage defectTrackerVulnMap = new ActiveMQMapMessage();
try {
defectTrackerVulnMap.setInt("appId", appId);
defectTrackerVulnMap.setString("type", QueueConstants.DEFECT_TRACKER_VULN_UPDATE_TYPE);
defectTrackerVulnMap.setString("urlPath",
"/organizations/" + orgId + "/applications/" + appId);
defectTrackerVulnMap.setString("urlText", "Go to Application");
} catch (JMSException e) {
log.error(jmsErrorString);
e.printStackTrace();
}
sendMap(defectTrackerVulnMap);
}
开发者ID:jqxin2006,项目名称:threadfixRack,代码行数:26,代码来源:QueueSenderImpl.java
示例7: addRemoteProviderImport
import org.apache.activemq.command.ActiveMQMapMessage; //导入依赖的package包/类
public void addRemoteProviderImport(RemoteProviderType remoteProviderType) {
String userName = SecurityContextHolder.getContext().getAuthentication().getName();
log.info("User " + userName + " is adding a remote provider import to the queue for " +
remoteProviderType.getName() + ".");
MapMessage remoteProviderImportMap = new ActiveMQMapMessage();
try {
remoteProviderImportMap.setObject("remoteProviderTypeId", remoteProviderType.getId());
remoteProviderImportMap.setString("type", QueueConstants.IMPORT_REMOTE_PROVIDER_SCANS_REQUEST);
} catch (JMSException e) {
log.error(jmsErrorString);
e.printStackTrace();
}
sendMap(remoteProviderImportMap);
}
开发者ID:jqxin2006,项目名称:threadfixRack,代码行数:19,代码来源:QueueSenderImpl.java
示例8: createMessage
import org.apache.activemq.command.ActiveMQMapMessage; //导入依赖的package包/类
public Message createMessage(Session session) throws JMSException {
Double value = LAST_PRICES.get(stock);
if (value == null) {
value = new Double(Math.random() * 100);
}
// lets mutate the value by some percentage
double oldPrice = value.doubleValue();
value = new Double(mutatePrice(oldPrice));
LAST_PRICES.put(stock, value);
double price = value.doubleValue();
double offer = price * 1.001;
boolean up = (price > oldPrice);
MapMessage message = session.createMapMessage();
message.setString("stock", stock.toString());
message.setDouble("price", price);
message.setDouble("offer", offer);
message.setBoolean("up", up);
System.out.println("Sending: " + ((ActiveMQMapMessage)message).getContentMap() + " on destination: " + stock);
return message;
}
开发者ID:xuzhikethinker,项目名称:t4f-data,代码行数:24,代码来源:StockMessageCreator.java
示例9: createMessage
import org.apache.activemq.command.ActiveMQMapMessage; //导入依赖的package包/类
public Message createMessage(Session session) throws JMSException {
double i = Math.random();
MapMessage mapMessage = session.createMapMessage();
mapMessage.setString("action", "action_"+i);
mapMessage.setString("ID", "ID"+i);
mapMessage.setString("description", "messageStr"+i);
_log.debug("Sending: " + ((ActiveMQMapMessage)mapMessage).getContentMap() + " on destination: " + destination);
return mapMessage;
}
开发者ID:giuseppeurso-eu,项目名称:activemq,代码行数:10,代码来源:ProducerMessageCreator.java
示例10: log
import org.apache.activemq.command.ActiveMQMapMessage; //导入依赖的package包/类
private void log(String what, Message messageSend) {
String mats = "";
if (messageSend instanceof ActiveMQMapMessage) {
ActiveMQMapMessage matsMm = (ActiveMQMapMessage) messageSend;
String matsTrace;
try {
matsTrace = matsMm.getString("mats:trace");// TODO: Use static.
if (matsTrace != null) {
mats = "\n\n MATS:"
+ "\n MatsTrace: " + matsTrace;
}
}
catch (JMSException e) {
throw new AssertionError("Getting a String from ActiveMqMapMessage threw!", e);
}
}
if (log.isDebugEnabled()) {
log.debug(LOG_PREFIX + '\n' + what + ": " + messageSend.getClass().getSimpleName()
+ '@' + Integer.toHexString(System.identityHashCode(messageSend))
+ "\n currentTimeMillis: " + System.currentTimeMillis()
+ "\n Timestamp: " + messageSend.getTimestamp()
+ "\n BrokerInTime: " + messageSend.getBrokerInTime()
+ "\n BrokerOutTime: " + messageSend.getBrokerInTime()
+ "\n MessageId: " + messageSend.getMessageId()
+ "\n ProducerId: " + messageSend.getProducerId()
+ "\n TransactionId: " + messageSend.getTransactionId()
+ "\n OrigTransactionId: " + messageSend.getOriginalTransactionId()
+ "\n Destination: " + messageSend.getDestination()
+ "\n OrigDestination: " + messageSend.getOriginalDestination()
+ "\n Size: " + messageSend.getSize()
+ "\n RedeliveryCounter: " + messageSend.getRedeliveryCounter()
+ mats);
}
}
开发者ID:stolsvik,项目名称:mats,代码行数:35,代码来源:MatsLoggingBrokerPlugin.java
示例11: sendSubStats
import org.apache.activemq.command.ActiveMQMapMessage; //导入依赖的package包/类
protected void sendSubStats(ConnectionContext context, ObjectName[] subscribers, ActiveMQDestination replyTo) throws Exception {
for (int i = 0; i < subscribers.length; i++) {
ObjectName name = subscribers[i];
SubscriptionViewMBean subscriber = (SubscriptionViewMBean)getBrokerService().getManagementContext().newProxyInstance(name, SubscriptionViewMBean.class, true);
ActiveMQMapMessage statsMessage = prepareSubscriptionMessage(subscriber);
sendStats(context, statsMessage, replyTo);
}
}
开发者ID:DiamondLightSource,项目名称:daq-eclipse,代码行数:9,代码来源:StatisticsBroker.java
示例12: getFields
import org.apache.activemq.command.ActiveMQMapMessage; //导入依赖的package包/类
@Override
public Map<String, Object> getFields(Object o) throws OpenDataException {
ActiveMQMapMessage m = (ActiveMQMapMessage)o;
Map<String, Object> rc = super.getFields(o);
try {
rc.put(CompositeDataConstants.CONTENT_MAP, "" + m.getContentMap());
} catch (JMSException e) {
rc.put(CompositeDataConstants.CONTENT_MAP, "");
}
return rc;
}
开发者ID:DiamondLightSource,项目名称:daq-eclipse,代码行数:12,代码来源:OpenTypeSupport.java
示例13: createMapMessage
import org.apache.activemq.command.ActiveMQMapMessage; //导入依赖的package包/类
@SuppressWarnings("unchecked")
protected ActiveMQMapMessage createMapMessage(HierarchicalStreamReader in) throws JMSException {
ActiveMQMapMessage mapMsg = new ActiveMQMapMessage();
Map<String, Object> map = (Map<String, Object>)getXStream().unmarshal(in);
for (String key : map.keySet()) {
mapMsg.setObject(key, map.get(key));
}
return mapMsg;
}
开发者ID:DiamondLightSource,项目名称:daq-eclipse,代码行数:10,代码来源:JmsFrameTranslator.java
示例14: onMessage
import org.apache.activemq.command.ActiveMQMapMessage; //导入依赖的package包/类
public void onMessage(Message object) {
try {
ActiveMQMapMessage message = (ActiveMQMapMessage) object;
String userId = message.getString("userId");
String msg = message.getString("chatMessage");
this.taChat.append(userId + ": " + msg + "\n");
} catch (JMSException e) {
e.printStackTrace();
}
}
开发者ID:v5developer,项目名称:maven-framework-project,代码行数:11,代码来源:JMSChat.java
示例15: addSubmitDefect
import org.apache.activemq.command.ActiveMQMapMessage; //导入依赖的package包/类
@Override
public void addSubmitDefect(List<Integer> vulnerabilityIds, String summary,
String preamble, String component, String version, String severity,
String priority, String status, Integer orgId, Integer applicationId) {
String userName = SecurityContextHolder.getContext().getAuthentication().getName();
log.info("User " + userName + " is adding a defect submission to the queue for " + vulnerabilityIds.size() + " vulnerabilities from Application with ID " + applicationId + ".");
MapMessage submitDefectMap = new ActiveMQMapMessage();
try {
submitDefectMap.setObject("vulnerabilityIds", vulnerabilityIds);
submitDefectMap.setString("summary", summary);
submitDefectMap.setString("preamble", preamble);
submitDefectMap.setString("component", component);
submitDefectMap.setString("version", version);
submitDefectMap.setString("severity", severity);
submitDefectMap.setString("priority", priority);
submitDefectMap.setString("status", status);
submitDefectMap.setString("type", QueueConstants.SUBMIT_DEFECT_TYPE);
submitDefectMap.setString("urlPath", "/organizations/"
+ orgId + "/applications/" + applicationId + "/defects");
submitDefectMap.setString("urlText", "Submit more defects");
} catch (JMSException e) {
log.error(jmsErrorString);
e.printStackTrace();
}
sendMap(submitDefectMap);
}
开发者ID:jqxin2006,项目名称:threadfixRack,代码行数:32,代码来源:QueueSenderImpl.java
示例16: getBody
import org.apache.activemq.command.ActiveMQMapMessage; //导入依赖的package包/类
@Override
public <T> T getBody(final Class<T> c) throws JMSException {
if (isBodyAssignableTo(c)) {
return c.cast(ActiveMQMapMessage.class.isInstance(message) ?
ActiveMQMapMessage.class.cast(message).getContentMap() : message /* unlikely */);
}
throw new MessageFormatException("Can't get the body with type " + c);
}
开发者ID:apache,项目名称:tomee,代码行数:9,代码来源:WrappingMapMessage.java
示例17: onMessage
import org.apache.activemq.command.ActiveMQMapMessage; //导入依赖的package包/类
public void onMessage(Message message) {
try {
System.out.println("Message " + ((ActiveMQMapMessage)message).getContentMap() + " not consumed by any consumer");
} catch (Exception e) {
e.printStackTrace();
}
}
开发者ID:xuzhikethinker,项目名称:t4f-data,代码行数:8,代码来源:NoConsumerAdvisoryListener.java
示例18: sendMessage
import org.apache.activemq.command.ActiveMQMapMessage; //导入依赖的package包/类
protected void sendMessage(String[] stocks) throws JMSException {
int idx = 0;
while (true) {
idx = (int)Math.round(stocks.length * Math.random());
if (idx < stocks.length) {
break;
}
}
String stock = stocks[idx];
Destination destination = session.createTopic("STOCKS." + stock);
Message message = createStockMessage(stock, session);
System.out.println("Sending: " + ((ActiveMQMapMessage)message).getContentMap() + " on destination: " + destination);
producer.send(destination, message);
}
开发者ID:xuzhikethinker,项目名称:t4f-data,代码行数:15,代码来源:Publisher.java
示例19: sendMessage
import org.apache.activemq.command.ActiveMQMapMessage; //导入依赖的package包/类
public void sendMessage(String[] stocks) throws JMSException {
int idx = 0;
while (true) {
idx = (int)Math.round(stocks.length * Math.random());
if (idx < stocks.length) {
break;
}
}
String stock = stocks[idx];
Destination destination = session.createTopic("STOCKS." + stock);
Message message = createStockMessage(stock, session);
System.out.println("Sending: " + ((ActiveMQMapMessage)message).getContentMap() + " on destination: " + destination);
producer.send(destination, message);
}
开发者ID:xuzhikethinker,项目名称:t4f-data,代码行数:15,代码来源:Publisher.java
示例20: getTypeName
import org.apache.activemq.command.ActiveMQMapMessage; //导入依赖的package包/类
@Override
protected String getTypeName() {
return ActiveMQMapMessage.class.getName();
}
开发者ID:DiamondLightSource,项目名称:daq-eclipse,代码行数:5,代码来源:OpenTypeSupport.java
注:本文中的org.apache.activemq.command.ActiveMQMapMessage类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论