Examples of version()

Examples of net.kuujo.vertigo.network.NetworkContext.version()

995
996
997
998
999
1000
1001
1002
1003
1004
1005
          // to watch the network's status key for notification once the configuration
          // change is complete.
          data.watch(context.status(), MapEvent.Type.CHANGE, new Handler<MapEvent<String, String>>() {
            @Override
            public void handle(MapEvent<String, String> event) {
              if (event.value() != null && event.value().equals(context.version())) {
                // The network's configuration has been completely updated. Stop watching
                // the network's status key and call the async handler.
                data.unwatch(context.status(), null, this, new Handler<AsyncResult<Void>>() {
                  @Override
                  public void handle(AsyncResult<Void> result) {
View Full Code Here

Examples of net.opentsdb.tsd.RpcPlugin.version()

228
229
230
231
232
233
234
235
236
237
238
          rpc_plugins = new ArrayList<RpcPlugin>(1);
        }
        rpc_plugins.add(rpc);
        LOG.info("Successfully initialized RPC plugin [" +
            rpc.getClass().getCanonicalName() + "] version: "
            + rpc.version());
      }
    }
  }
 
  /**
 
View Full Code Here

Examples of net.tomp2p.message.Message.version()

231
232
233
234
235
236
237
238
239
240
241
              "There are no PeerSocketAdresses available for this relayed Peer. This should not be possible!");
    }
    // we need to make a copy of the original message
    Message rconMessage = new Message();
    rconMessage.sender(message.sender());
    rconMessage.version(message.version());
    // store the message id in the payload to get the cached message later
    rconMessage.intValue(message.messageId());
    // the message must have set the keepAlive Flag true. If not, the relay
    // peer will close the PeerConnection to the unreachable peer.
    rconMessage.keepAlive(true);
View Full Code Here

Examples of net.xeoh.plugins.base.annotations.meta.Version.version()

100
101
102
103
104
105
106
107
108
109
110
            break;

        case VERSION:
            final Version version = plugin.getClass().getAnnotation(Version.class);
            if (version == null) break;
            rval.add(Integer.toString(version.version()));
           
            if(plugin == this.pluginManager) {
                final String build = $(PluginManagerImpl.class.getResourceAsStream("jspf.version")).text().split("\n").hashmap().get("build");
                rval.add("jspf.build:" + build);
            }
View Full Code Here

Examples of org.apache.abdera.ext.serializer.annotation.Generator.version()

71
72
73
74
75
76
77
78
79
80
81
            URI _version = objectContext.getAnnotation(URI.class);
            if (_version != null && !_version.value().equals(DEFAULT)) {
                version = _version.value();
            }
        }
        if (version == null && _generator != null && !_generator.version().equals(DEFAULT)) {
            version = _generator.version();
        }
        if (version != null)
            sw.writeAttribute("version", version);
View Full Code Here

Examples of org.apache.drill.common.logical.PlanProperties.PlanPropertiesBuilder.version()

70
71
72
73
74
75
76
77
78
79
80
      return plan;
    }

    PlanPropertiesBuilder propsBuilder = PlanProperties.builder();
    propsBuilder.type(PlanType.APACHE_DRILL_PHYSICAL);
    propsBuilder.version(1);
    propsBuilder.resultMode(ResultMode.EXEC);
    propsBuilder.generator(PhysicalPlanCreator.class.getName(), "");


    try {
View Full Code Here

Examples of org.apache.hadoop.hive.ql.io.orc.OrcFile.WriterOptions.version()

225
226
227
228
229
230
231
232
233
234
235
                    path,
                    conf));
        }
        Version formatVersion = conf.getFormatVersion();
        if (formatVersion != null) {
            options.version(formatVersion);
        }
        CompressionKind compressionKind = conf.getCompressionKind();
        if (compressionKind != null) {
            options.compress(compressionKind);
        }
View Full Code Here

Examples of org.apache.struts2.json.annotations.SMD.version()

238
239
240
241
242
243
244
245
246
247
248
        // customize SMD
        SMD smdAnnotation = (SMD) clazz.getAnnotation(SMD.class);
        if (smdAnnotation != null) {
            smd.setObjectName(smdAnnotation.objectName());
            smd.setServiceType(smdAnnotation.serviceType());
            smd.setVersion(smdAnnotation.version());
        }

        // get public methods
        Method[] methods = JSONUtil.listSMDMethods(clazz, ignoreInterfaces);
View Full Code Here

Examples of org.codehaus.jackson.map.ObjectMapper.version()

52
53
54
55
56
57
58
59
60
61
62
    {
        ObjectMapper mapper = new ObjectMapper();
        /* 06-Sep-2010, tatus: This was not fixed for 1.6; and to keep junit test
         *   suite green, let's not run it for versions prior to 1.7...
         */
        Version v = mapper.version();
        if (v.getMajorVersion() == 1 && v.getMinorVersion() == 6) {
            System.err.println("Note: skipping test for Jackson 1.6");
            return;
        }
       
View Full Code Here

Examples of org.codehaus.plexus.component.annotations.Component.version()

73
74
75
76
77
78
79
80
81
82
83
        component.setRoleHint(filterEmptyAsNull(anno.hint()));

        component.setImplementation(className);

        component.setVersion(filterEmptyAsNull(anno.version()));

        component.setComponentType(filterEmptyAsNull(anno.type()));

        component.setInstantiationStrategy(filterEmptyAsNull(anno.instantiationStrategy()));
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.