...
| Bloque de código | ||
|---|---|---|
| ||
@MessageDriven(activationConfig = {
@ActivationConfigProperty(
propertyName = "destinationType",
propertyValue = "javax.jms.Topic"
),
@ActivationConfigProperty(
propertyName = "destination",
propertyValue = "topic/pruebaPushTopic"
)
})
@Name("pushReceiver")
public class PushReceiver implements MessageListener {
@Logger
private Log log;
@Override
public void onMessage(Message jmsMessage) {
try {
String message = jmsMessage.getStringProperty("message");
Events.instance().raiseEvent(new PushEventPushEventString(message));
} catch (JMSException ex) {
log.error("Problem sending push event message.", ex);
}
}
} |
...