1 | public static synchronized TopicConnectionFactory getTopicConnectionFactory(Context ctx, String fac) {↵ | | 1 | public static synchronized QueueConnectionFactory getQueueConnectionFactory(Context ctx, String fac) {↵
|
2 | while (factory == null) {↵ | | 2 | while (qfactory == null) {↵
|
3 | try {↵ | | 3 | try {↵
|
4 | Object objfac = ctx.lookup(fac);↵ | | 4 | Object objfac = ctx.lookup(fac);↵
|
5 | if (objfac instanceof TopicConnectionFactory) {↵ | | 5 | if (objfac instanceof QueueConnectionFactory) {↵
|
6 | factory = (TopicConnectionFactory) objfac;↵ | | 6 | qfactory = (QueueConnectionFactory) objfac;↵
|
7 | }↵ | | 7 | }↵
|
8 | } catch (NamingException e) {↵ | | 8 | } catch (NamingException e) {↵
|
9 | log.error(e.toString());↵ | | 9 | log.error(e.getMessage());↵
|
10 | }↵ | | 10 | }↵
|
11 | }↵ | | 11 | }↵
|
12 | return factory;↵ | | 12 | return qfactory;↵
|
13 | | | 13 |
|