Examples of DirectRouter

Examples of com.xiaomi.common.service.dal.routing.router.DirectRouter

117
118
119
120
121
122
123
124
125
126
127
            return factory.setColumn(conf[2]).setPattern(conf[3]).createRouter();
        } else if (DIRECT.equalsIgnoreCase(conf[0])) {
            RouterFactory factory = new RouterFactory(DIRECT) {
                @Override
                public Router onCreateRouter(String column, String pattern, int partitions) {
                    return new DirectRouter(column, pattern);
                }
            };
            return factory.setColumn(conf[2]).setPattern(conf[3]).createRouter();
        } else if (ROUND.equalsIgnoreCase(conf[0])) {
            RouterFactory factory = new RouterFactory(ROUND) {
View Full Code Here

Examples of org.mule.jbi.nmr.DirectRouter

199
200
201
202
203
204
205
206
207
208
209
      }
      if (getRegistry() == null) {
        context.setRegistry(new XmlRegistryStore(context).create(regStore.getAbsolutePath(), new JbiRegistryFactory()));
      }
      if (this.router == null) {
        this.router = new InternalMessageRouter(this, new DirectRouter(getRegistry()));
      }
    } catch (Exception e) {
      if (e instanceof JBIException) {
        throw (JBIException) e;
      } else {
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.