public abstract class ServiceDestination extends Object
Modifier and Type | Field and Description |
---|---|
static String |
ADMIN_HOST |
static String |
ADMIN_PORT |
static String |
ADMIN_USERNAME |
static String |
ADMIN_WRAPPER |
protected org.osgi.framework.BundleContext |
bundleContext |
protected HashMap<String,Destination> |
destinations |
static String |
DMQ |
static String |
DMQ_SID |
static String |
FREEREADING |
static String |
FREEWRITING |
private JndiHelper |
jndiHelper |
static String |
JNDINAME |
protected HashMap<String,String> |
jndiNames |
static org.objectweb.util.monolog.api.Logger |
logmon |
static String |
NAME |
static String |
NB_MAXMSG |
static String |
READERS |
protected HashMap<String,org.osgi.framework.ServiceRegistration> |
registrations |
static String |
SERVERID |
static String |
THRESHOLD |
static String |
TYPE |
static String |
WRITERS |
Constructor and Description |
---|
ServiceDestination(org.osgi.framework.BundleContext bundleContext) |
Modifier and Type | Method and Description |
---|---|
private Destination |
createDestination(AdminItf wrapper,
int serverId,
String name,
String className,
Properties props,
boolean isQueue) |
void |
deleted(String pid) |
void |
doUpdated(String pid,
Dictionary properties,
String className,
boolean isQueue)
Create the destination
|
private User |
getUser(AdminItf wrapper,
String user,
int serverId) |
protected boolean |
isSet(String value) |
private void |
setDestinationDMQ(AdminItf wrapper,
Destination dest,
String dmq,
int dmqSid) |
private void |
setQueueThreshold(Queue queue,
String thresholdStr,
String nbMaxMsgStr) |
private void |
setRight(AdminItf wrapper,
Destination dest,
int serverId,
boolean freeReading,
boolean freeWriting,
String readers,
String writers) |
public static final org.objectweb.util.monolog.api.Logger logmon
public static final String ADMIN_WRAPPER
public static final String ADMIN_HOST
public static final String ADMIN_PORT
public static final String ADMIN_USERNAME
public static final String NAME
public static final String SERVERID
public static final String TYPE
public static final String FREEREADING
public static final String FREEWRITING
public static final String READERS
public static final String WRITERS
public static final String THRESHOLD
public static final String NB_MAXMSG
public static final String JNDINAME
public static final String DMQ
public static final String DMQ_SID
protected org.osgi.framework.BundleContext bundleContext
protected HashMap<String,Destination> destinations
private JndiHelper jndiHelper
public ServiceDestination(org.osgi.framework.BundleContext bundleContext)
protected final boolean isSet(String value)
private Destination createDestination(AdminItf wrapper, int serverId, String name, String className, Properties props, boolean isQueue) throws ConnectException, AdminException
ConnectException
AdminException
private User getUser(AdminItf wrapper, String user, int serverId) throws ConnectException, AdminException
ConnectException
AdminException
private void setRight(AdminItf wrapper, Destination dest, int serverId, boolean freeReading, boolean freeWriting, String readers, String writers) throws ConnectException, AdminException
ConnectException
AdminException
private void setQueueThreshold(Queue queue, String thresholdStr, String nbMaxMsgStr) throws ConnectException, AdminException
ConnectException
AdminException
private void setDestinationDMQ(AdminItf wrapper, Destination dest, String dmq, int dmqSid) throws ConnectException, AdminException
ConnectException
AdminException
public void doUpdated(String pid, Dictionary properties, String className, boolean isQueue)
pid
- the pidproperties
- the destination propertiespublic void deleted(String pid)
Copyright © 2020 ScalAgent D.T.. All rights reserved.