public interface StreamConnection
extends javax.jms.Connection
Modifier and Type | Method and Description |
---|---|
InputStream |
createDurableInputStream(javax.jms.Topic dest,
String name) |
InputStream |
createDurableInputStream(javax.jms.Topic dest,
String name,
String messageSelector) |
InputStream |
createDurableInputStream(javax.jms.Topic dest,
String name,
String messageSelector,
boolean noLocal) |
InputStream |
createDurableInputStream(javax.jms.Topic dest,
String name,
String messageSelector,
boolean noLocal,
long timeout) |
InputStream |
createInputStream(javax.jms.Destination dest) |
InputStream |
createInputStream(javax.jms.Destination dest,
String messageSelector) |
InputStream |
createInputStream(javax.jms.Destination dest,
String messageSelector,
boolean noLocal) |
InputStream |
createInputStream(javax.jms.Destination dest,
String messageSelector,
boolean noLocal,
long timeout) |
OutputStream |
createOutputStream(javax.jms.Destination dest) |
OutputStream |
createOutputStream(javax.jms.Destination dest,
Map<String,Object> streamProperties,
int deliveryMode,
int priority,
long timeToLive) |
void |
unsubscribe(String name)
Unsubscribes a durable subscription that has been created by a client.
|
InputStream createInputStream(javax.jms.Destination dest) throws javax.jms.JMSException
javax.jms.JMSException
InputStream createInputStream(javax.jms.Destination dest, String messageSelector) throws javax.jms.JMSException
javax.jms.JMSException
InputStream createInputStream(javax.jms.Destination dest, String messageSelector, boolean noLocal) throws javax.jms.JMSException
javax.jms.JMSException
InputStream createInputStream(javax.jms.Destination dest, String messageSelector, boolean noLocal, long timeout) throws javax.jms.JMSException
javax.jms.JMSException
InputStream createDurableInputStream(javax.jms.Topic dest, String name) throws javax.jms.JMSException
javax.jms.JMSException
InputStream createDurableInputStream(javax.jms.Topic dest, String name, String messageSelector) throws javax.jms.JMSException
javax.jms.JMSException
InputStream createDurableInputStream(javax.jms.Topic dest, String name, String messageSelector, boolean noLocal) throws javax.jms.JMSException
javax.jms.JMSException
InputStream createDurableInputStream(javax.jms.Topic dest, String name, String messageSelector, boolean noLocal, long timeout) throws javax.jms.JMSException
javax.jms.JMSException
OutputStream createOutputStream(javax.jms.Destination dest) throws javax.jms.JMSException
javax.jms.JMSException
OutputStream createOutputStream(javax.jms.Destination dest, Map<String,Object> streamProperties, int deliveryMode, int priority, long timeToLive) throws javax.jms.JMSException
javax.jms.JMSException
void unsubscribe(String name) throws javax.jms.JMSException
This method deletes the state being maintained on behalf of the subscriber by its provider.
It is erroneous for a client to delete a durable subscription while there
is an active MessageConsumer
or
TopicSubscriber
for the subscription, or while a consumed
message is part of a pending transaction or has not been acknowledged in
the session.
name
- the name used to identify this subscriptionjavax.jms.JMSException
- if the session fails to unsubscribe to the durable
subscription due to some internal error.javax.jms.InvalidDestinationException
- if an invalid subscription name is
specified.Copyright © 2005–2017 The Apache Software Foundation. All rights reserved.