@Inject public ApiServerChannelInitializer(ObjectMapper objectMapper, ApiProtocolSwitcher apiProtocolSwitcher, // ObservableEncoder rxjavaHandler, GeneratedJaxRsModuleHandler jaxRsModuleHandler) { this.apiProtocolSwitcher = apiProtocolSwitcher; // this.rxjavaHandler = rxjavaHandler; this.jaxRsHandlers = jaxRsModuleHandler; SimpleModule nettyModule = new SimpleModule("Netty", PackageVersion.VERSION); nettyModule.addSerializer(new ByteBufSerializer()); objectMapper.registerModule(nettyModule); // TODO: allow customization of the thread pool! // rxJavaGroup = new DefaultEventExecutorGroup(4, new DefaultThreadFactory("rxjava")); jaxRsGroup = new DefaultEventExecutorGroup(Runtime.getRuntime().availableProcessors(), new DefaultThreadFactory("jax-rs")); }
@Inject public ApiServerChannelInitializer(ObjectMapper objectMapper, ApiProtocolSwitcher apiProtocolSwitcher, SecurityManager securityManager, GeneratedJaxRsModuleHandler jaxRsModuleHandler) { this.apiProtocolSwitcher = apiProtocolSwitcher; this.jaxRsHandlers = jaxRsModuleHandler; this.shiroHandler = new ShiroHandler(securityManager); this.userLoggingHandler = new UserLoggingHandler(); SimpleModule nettyModule = new SimpleModule("Netty", PackageVersion.VERSION); nettyModule.addSerializer(new ByteBufSerializer()); objectMapper.registerModule(nettyModule); }
public void testPackageVersionMatches() { assertEquals(PackageVersion.VERSION, VersionUtil.versionFor(UTF8JsonGenerator.class)); }
public Version version() { return PackageVersion.VERSION; }
@Override public Version version() { return PackageVersion.VERSION; }
/** * Implemented with standard version number detection algorithm, typically using * a simple generated class, with information extracted from Maven project file * during build. */ @Override public Version version() { return PackageVersion.VERSION; }