Java Message类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中org.springframework.integration.Message类的典型用法代码示例。如果您正苦于以下问题：Java Message类的具体用法？Java Message怎么用？Java Message使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

Message类属于org.springframework.integration包，在下文中一共展示了Message类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: handle

import org.springframework.integration.Message; //导入依赖的package包/类
/**
 * @param message
 * @throws Exception
 */
public void handle(Message<?> message, MessageChannel channel, Boolean sent) {
	if(message != null) {
		logger.info("Got a message:");
		logger.info(message.toString());
		messages.add(message);
		logger.info("The Payload was:");
		try {
			logger.info(message.getPayload().toString() + ":" + BeanUtils.describe(message.getPayload()));
		} catch (Exception e) {
			logger.error("Error trying to describe the payload.", e);
		}
		logger.info("There are now " + messages.size() + " messages.");
	} else {
		logger.info("Got a null message.");
	}
	/*if(channel != null) {
           logger.info("With channel: " + channel);
           if(channel.equals(primaryChannel)) {
               messages.add(message);
           }
       }*/
}

开发者ID:RBGKew，项目名称:eMonocot，代码行数:27，代码来源:MessageHandler.java

示例2: doSend

import org.springframework.integration.Message; //导入依赖的package包/类
protected boolean doSend(Message<?> message, long timeout) {
	Assert.notNull(message, "'message' must not be null");
	try {
		if (timeout > 0) {
			return this.queue
					.offer(message, timeout, TimeUnit.MILLISECONDS);
		}
		if (timeout == 0) {
			return this.queue.offer(message);
		}
		queue.put(message);
		return true;
	} catch (InterruptedException e) {
		Thread.currentThread().interrupt();
		return false;
	}
}

开发者ID:mattiamascia，项目名称:atask，代码行数:18，代码来源:AsyncChannel.java

示例3: run

import org.springframework.integration.Message; //导入依赖的package包/类
@Override
public void run() {
	while (messageLoop) {
		final Message<?> message = sqsExecutor.poll();
		if (message != null) {
			try {
				workerThreadPool.execute(new Runnable() {

					@Override
					public void run() {
						sendMessage(message);
						sqsExecutor.acknowlegdeReceipt(message);
						log.debug("Message sent...");
					}
				});
			} catch (Throwable t) {
				log.warn(t.getMessage(), t);
			}
		}
	}
}

开发者ID:3pillarlabs，项目名称:spring-integration-aws，代码行数:22，代码来源:SqsSubscribableChannelAdapter.java

示例4: receive

import org.springframework.integration.Message; //导入依赖的package包/类
@Override
public Message<Object> receive() {
	Message<Object> message = null;
	Message<?> incoming = null;
	try {
		incoming = sqsExecutor.poll();
	} catch (Throwable t) {
		log.warn(t.getMessage(), t);
	}
	if (incoming != null) {
		Object payload = incoming.getPayload();
		final Message<?> callBackRef = incoming;
		message = MessageBuilder.withPayload(payload)
				.copyHeaders(incoming.getHeaders())
				.setHeader(SqsHeaders.ACK_CALLBACK, new Callable<String>() {

					@Override
					public String call() throws Exception {
						return sqsExecutor.acknowlegdeReceipt(callBackRef);
					}
				}).build();
	}
	return message;
}

开发者ID:3pillarlabs，项目名称:spring-integration-aws，代码行数:25，代码来源:SqsSubscribableChannelAdapter.java

示例5: run

import org.springframework.integration.Message; //导入依赖的package包/类
@Override
public void run() {
	while (messageLoop) {
		final Message<?> message = sqsExecutor.poll();
		if (message != null) {
			workerThreadPool.execute(new Runnable() {

				@Override
				public void run() {
					try {
						dispatcher.dispatch(message);
						sqsExecutor.acknowlegdeReceipt(message);
						log.debug("Message dispatched...");
					} catch (Throwable t) {
						log.warn(t.getMessage(), t);
					}
				}

			});
		}
	}
}

开发者ID:3pillarlabs，项目名称:spring-integration-aws，代码行数:23，代码来源:SubscribableSqsChannel.java

示例6: receive

import org.springframework.integration.Message; //导入依赖的package包/类
@Override
public Message<?> receive(long timeout) {
	Message<?> message = null;
	Message<?> incoming = null;
	try {
		if (timeout > 0) {
			incoming = sqsExecutor.poll(timeout);
		} else {
			incoming = sqsExecutor.poll();
		}
	} catch (Throwable t) {
		log.warn(t.getMessage(), t);
	}
	if (incoming != null) {
		final Message<?> callBackRef = incoming;
		message = MessageBuilder.fromMessage(incoming)
				.setHeader(SqsHeaders.ACK_CALLBACK, new Callable<String>() {

					@Override
					public String call() throws Exception {
						return sqsExecutor.acknowlegdeReceipt(callBackRef);
					}
				}).build();
	}
	return message;
}

开发者ID:3pillarlabs，项目名称:spring-integration-aws，代码行数:27，代码来源:SubscribableSqsChannel.java

示例7: executeOutboundOperation

import org.springframework.integration.Message; //导入依赖的package包/类
/**
 * Executes the outbound Sqs Operation.
 * 
 */
public Object executeOutboundOperation(final Message<?> message) {

	try {
		String serializedMessage = messageMarshaller.serialize(message);
		if (queue == null) {
			SendMessageRequest request = new SendMessageRequest(queueUrl,
					serializedMessage);
			SendMessageResult result = sqsClient.sendMessage(request);
			log.debug("Message sent, Id:" + result.getMessageId());
		} else {
			queue.add(serializedMessage);
		}
	} catch (MessageMarshallerException e) {
		log.error(e.getMessage(), e);
		throw new MessagingException(e.getMessage(), e.getCause());
	}

	return message.getPayload();
}

开发者ID:3pillarlabs，项目名称:spring-integration-aws，代码行数:24，代码来源:SqsExecutor.java

示例8: onInit

import org.springframework.integration.Message; //导入依赖的package包/类
/**
 * Check for mandatory attributes
 */
@Override
protected void onInit() {
	super.onInit();

	Assert.notNull(snsExecutor, "snsExecutor must not be null.");

	this.notificationHandler = new NotificationHandler() {

		@Override
		protected void dispatch(Message<?> message) {
			sendMessage(message);
		}
	};

	log.info("SNS inbound adapter: [" + getComponentName()
			+ "], initialized...");
}

开发者ID:3pillarlabs，项目名称:spring-integration-aws，代码行数:21，代码来源:SnsInboundChannelAdapter.java

示例9: executeOutboundOperation

import org.springframework.integration.Message; //导入依赖的package包/类
/**
 * Executes the outbound Sns Operation.
 * 
 */
public Object executeOutboundOperation(final Message<?> message) {

	try {
		String serializedMessage = messageMarshaller.serialize(message);

		if (snsTestProxy == null) {
			PublishRequest request = new PublishRequest();
			PublishResult result = client.publish(request.withTopicArn(
					topicArn).withMessage(serializedMessage));
			log.debug("Published message to topic: "
					+ result.getMessageId());
		} else {
			snsTestProxy.dispatchMessage(serializedMessage);
		}

	} catch (MessageMarshallerException e) {
		log.error(e.getMessage(), e);
		throw new MessagingException(e.getMessage(), e.getCause());
	}

	return message.getPayload();
}

开发者ID:3pillarlabs，项目名称:spring-integration-aws，代码行数:27，代码来源:SnsExecutor.java

示例10: testArrayOfPojo

import org.springframework.integration.Message; //导入依赖的package包/类
@Test
public void testArrayOfPojo() throws MessageMarshallerException {

	TestPojo[] aryIn = new TestPojo[2];
	aryIn[0] = new TestPojo();
	aryIn[0].setName("John Doe");
	aryIn[0].setEmail("[email protected]");
	aryIn[1] = new TestPojo();
	aryIn[1].setName("Lionel Messi");
	aryIn[1].setEmail("[email protected]");

	String packet = marshaller.serialize(MessageBuilder.withPayload(aryIn)
			.build());
	Message<?> otherPacket = marshaller.deserialize(packet);

	TestPojo[] aryOut = (TestPojo[]) otherPacket.getPayload();

	assertTrue(Arrays.deepEquals(aryIn, aryOut));

}

开发者ID:3pillarlabs，项目名称:spring-integration-aws，代码行数:21，代码来源:JsonMessageMarshallerTest.java

示例11: incorrectMD5Test

import org.springframework.integration.Message; //导入依赖的package包/类
@Test
public void incorrectMD5Test() throws MessageMarshallerException {

	String payload = "Hello, World";
	String messageBody = messageMarshaller.serialize(MessageBuilder
			.withPayload(payload).build());
	com.amazonaws.services.sqs.model.Message sqsMessage = new com.amazonaws.services.sqs.model.Message();
	sqsMessage.setBody(messageBody);
	sqsMessage.setMD5OfBody(messageBody);

	ReceiveMessageResult result = new ReceiveMessageResult();
	result.setMessages(Collections.singletonList(sqsMessage));
	when(mockSQS.receiveMessage(any(ReceiveMessageRequest.class)))
			.thenReturn(result);

	Message<?> recvMessage = executor.poll();
	assertNull("No message since MD5 checksum failed", recvMessage);
}

开发者ID:3pillarlabs，项目名称:spring-integration-aws，代码行数:19，代码来源:SqsExecutorTest.java

示例12: correctMD5Test

import org.springframework.integration.Message; //导入依赖的package包/类
@Test
public void correctMD5Test() throws Exception {

	String payload = "Hello, World";
	String messageBody = messageMarshaller.serialize(MessageBuilder
			.withPayload(payload).build());
	com.amazonaws.services.sqs.model.Message sqsMessage = new com.amazonaws.services.sqs.model.Message();
	sqsMessage.setBody(messageBody);
	sqsMessage.setMD5OfBody(new String(Hex.encodeHex(Md5Utils
			.computeMD5Hash(messageBody.getBytes("UTF-8")))));

	ReceiveMessageResult result = new ReceiveMessageResult();
	result.setMessages(Collections.singletonList(sqsMessage));
	when(mockSQS.receiveMessage(any(ReceiveMessageRequest.class)))
			.thenReturn(result);

	Message<?> recvMessage = executor.poll();
	assertNotNull("message is not null", recvMessage);

	Message<?> enclosed = messageMarshaller
			.deserialize((String) recvMessage.getPayload());
	String recvPayload = (String) enclosed.getPayload();
	assertEquals("payload must match", payload, recvPayload);
}

开发者ID:3pillarlabs，项目名称:spring-integration-aws，代码行数:25，代码来源:SqsExecutorTest.java

示例13: testMessageFlow

import org.springframework.integration.Message; //导入依赖的package包/类
@Test
public void testMessageFlow() throws Exception {

	setUp("SqsInboundChannelAdapterParserTests.xml", getClass(),
			"sqsInboundChannelAdapter");

	@SuppressWarnings("unchecked")
	BlockingQueue<String> testQueue = (BlockingQueue<String>) context
			.getBean("testQueue");
	DirectChannel out = (DirectChannel) context.getBean("out");
	out.subscribe(new MessageHandler() {

		@Override
		public void handleMessage(Message<?> message)
				throws MessagingException {
			assertEquals("Hello, World", message.getPayload());
		}
	});

	testQueue
			.add("{\"payload\": \"Hello, World\", \"payloadClazz\": \"java.lang.String\", \"headers\": {}, \"properties\": {}}");

}

开发者ID:3pillarlabs，项目名称:spring-integration-aws，代码行数:24，代码来源:SqsInboundChannelAdapterParserTests.java

示例14: testMessageDrivenFlow

import org.springframework.integration.Message; //导入依赖的package包/类
@Test
public void testMessageDrivenFlow() throws Exception {

	setUp("SqsChannelParserTests.xml", getClass(), "sqsChannel");

	recvMessage = null;
	DirectChannel log = (DirectChannel) context.getBean("log");
	log.subscribe(new MessageHandler() {

		@Override
		public void handleMessage(Message<?> message)
				throws MessagingException {
			recvMessage = (String) message.getPayload();
		}
	});

	String payload = "Hello, World";
	MessageChannel channel = (MessageChannel) context.getBean("sqsChannel");
	channel.send(MessageBuilder.withPayload(payload).build());
	Thread.sleep(1000);
	assertEquals(payload, recvMessage);
}

开发者ID:3pillarlabs，项目名称:spring-integration-aws，代码行数:23，代码来源:SqsChannelParserTests.java

示例15: testPollingFlow

import org.springframework.integration.Message; //导入依赖的package包/类
@Test
public void testPollingFlow() throws Exception {
	setUp("SqsPollingChannelParserTests.xml", getClass(), "sqsChannel");

	PollableChannel channel = (PollableChannel) context
			.getBean("sqsChannel");

	String payload = "Hello, World";
	channel.send(MessageBuilder.withPayload(payload).build());

	Message<?> recv = channel.receive(1000);
	assertEquals(payload, recv.getPayload());

	@SuppressWarnings("unchecked")
	Callable<String> ackCallback = (Callable<String>) recv.getHeaders()
			.get(SqsHeaders.ACK_CALLBACK);
	assertNotNull(ackCallback);
	assertTrue(ackCallback.call().isEmpty());
}

开发者ID:3pillarlabs，项目名称:spring-integration-aws，代码行数:20，代码来源:SqsChannelParserTests.java

示例16: testMessageFlow

import org.springframework.integration.Message; //导入依赖的package包/类
@Test
public void testMessageFlow() throws Exception {

	setUp("SnsChannelParserTests.xml", getClass(), "snsChannel");

	recvPayload = null;
	PublishSubscribeSnsChannel snsChannel = (PublishSubscribeSnsChannel) context
			.getBean("snsChannel");
	snsChannel.subscribe(new MessageHandler() {

		@Override
		public void handleMessage(Message<?> message)
				throws MessagingException {
			recvPayload = message.getPayload();
		}
	});

	String payload = "Hello, World";
	snsChannel.send(MessageBuilder.withPayload(payload).build());
	Thread.sleep(1000);

	assertNotNull(recvPayload);
	assertEquals(payload, recvPayload);
}

开发者ID:3pillarlabs，项目名称:spring-integration-aws，代码行数:25，代码来源:SnsChannelParserTests.java

示例17: process

import org.springframework.integration.Message; //导入依赖的package包/类
public PersonTax process(Person item) {
    	
        Message<?> inputMessage = MessageBuilder.withPayload(item).build();
//
        Message<?> outputMessage = this.messagingGateway.sendAndReceive(this.integrationInputChannel, inputMessage);

//        return outputMessage;
        
        PersonTax personTax = (PersonTax) outputMessage.getPayload();
        
        if (item.getDependents() > 0) {
			personTax.setFree(true);
		}else{
			personTax.setFree(false);
		}
        
        personTax.setDate(new Date(System.currentTimeMillis()));
		personTax.setTax(item.getSalary()*1.05);
        
    	return personTax;
    }

开发者ID:osnircunha，项目名称:SpringFrameworkSamples，代码行数:22，代码来源:MyItemProcessor.java

示例18: prepareMessage

import org.springframework.integration.Message; //导入依赖的package包/类
/**
 * Prepare a message for outgoing email
 *
 * @param message
 * @return
 */
public Message<Map> prepareMessage(Message<?> message) {
	Map<String, Object> model = new HashMap<String, Object>();
	Map<String, Object> headers = new HashMap<String, Object>();
	headers.putAll(message.getHeaders());
	Object payload = message.getPayload();
	if (payload instanceof Comment) {
		model.put("comment", payload);
		// Decide which template
		Base about = ((Comment) payload).getAboutData();
		String templateName = null;
		if(((Comment) payload).getInResponseTo() != null) {
			templateName = "reply";
		} else if (about instanceof BaseData) {
			templateName = "comment";
		} else if (about instanceof Resource) {
			templateName = "resource";
		}
		if (templateName != null) {
			headers.put(HEADER_TEMPLATE_NAME, templates.get(templateName));
		} else {
			headers.put(HEADER_TEMPLATE_NAME,
					templates.get(defaultTemplateName));
		}
	}
	return new GenericMessage<Map>(model, headers);

}

开发者ID:RBGKew，项目名称:eMonocot，代码行数:34，代码来源:EmailServiceHelper.java

示例19: splitMessage

import org.springframework.integration.Message; //导入依赖的package包/类
@Override
protected List<Message<Object>> splitMessage(Message<?> message) {
	List<Message<Object>> split = new ArrayList<Message<Object>>();
	Message<Object> m;
	for(Object o : (Iterable) message.getHeaders().get(requestKey)) {
		Map<String, Object> newHeaders = new HashMap<String, Object>();
		newHeaders.putAll(message.getHeaders());
		if(responseKey != null) {
			newHeaders.put(responseKey, o);
		}
		m = new GenericMessage<Object>(message.getPayload(), newHeaders);
		split.add(m);
	}
	return split;
}

开发者ID:RBGKew，项目名称:eMonocot，代码行数:16，代码来源:HeaderCollectionSplitter.java

示例20: process

import org.springframework.integration.Message; //导入依赖的package包/类
/**
 * Processes the thread id
 *
 * @param id the id
 * @return the async context
 */
public AsyncContext process(String id) {
	IdMessageSelector selector = (IdMessageSelector) ContextLoader
			.getCurrentWebApplicationContext().getBean(
					IdMessageSelector.BEAN);
	selector.setThreadId(id);
	List<Message<?>> listMessages = channel.purge(selector);
	if (listMessages.size() > 0) {
		Message<?> reportMessage = listMessages.get(0); // 1 a 1;
		if (reportMessage != null) {
			return (AsyncContext) reportMessage.getPayload();
		}
	}
	return null;
}

开发者ID:mattiamascia，项目名称:atask，代码行数:21，代码来源:DownloadCtr.java

注：本文中的org.springframework.integration.Message类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java ReactInstanceDevCommandsHandler类代码示例发布时间：2022-05-22

Java JPFLogger类代码示例发布时间：2022-05-22

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：18248|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9671|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8175|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8547|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8455|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9384|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8426|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7859|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8410|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7394|2022-11-06

客服电话

电子邮件

Java Message类代码示例

示例1: handle

示例2: doSend

示例3: run

示例4: receive

示例5: run

示例6: receive

示例7: executeOutboundOperation

示例8: onInit

示例9: executeOutboundOperation

示例10: testArrayOfPojo

示例11: incorrectMD5Test

示例12: correctMD5Test

示例13: testMessageFlow

示例14: testMessageDrivenFlow

示例15: testPollingFlow

示例16: testMessageFlow

示例17: process

示例18: prepareMessage

示例19: splitMessage

示例20: process

请发表评论

全部评论

上一篇：

下一篇：

bradtraversy/iweather: Ionic 3 mobile we

joaomh/curso-de-matlab

断牙刷新位置时间（断牙属性及刷新位置介绍

the-virtual-brain/tvb-library: DEPRECATE

rugk/mastodon-simplified-federation: Sim

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053