...
| Bloque de código | ||
|---|---|---|
| ||
@MessageDriven(activationConfig = {
@ActivationConfigProperty(
propertyName = "destinationType",
propertyValue = "javax.jms.QueueTopic"
),
@ActivationConfigProperty(
propertyName = "destination",
propertyValue = "topic/pruebaPushTopic"
)
})
@Name("pushReceiver")
public class pushReceiver implements MessageListener {
@Logger
private Log log;
@Push
private PushContext someChannel;
@Override
public void onMessage(Message message) {
try {
someChannel.send((ObjectMessage) message).getObject());
} catch (JMSException ex) {
log.error("Problem sending push event message.", ex);
}
}
} |
...