@Override public final void setupModule(final SetupContext setupContext) { SimpleKeyDeserializers keyDeserializers = new SimpleKeyDeserializers(); keyDeserializers.addDeserializer(Location.class, new GeographicalRegionKeyDeserializer()); setupContext.addKeyDeserializers(keyDeserializers); SimpleSerializers simpleSerializers = new SimpleSerializers(); simpleSerializers.addSerializer(new JobInstanceSerializer()); simpleSerializers.addSerializer(new JobExecutionSerializer()); setupContext.addSerializers(simpleSerializers); SimpleDeserializers simpleDeserializers = new SimpleDeserializers(); simpleDeserializers.addDeserializer(JobInstance.class, new JobInstanceDeserializer()); simpleDeserializers.addDeserializer(JobExecution.class, new JobExecutionDeserializer(jobInstanceService)); simpleDeserializers.addDeserializer(JobExecutionException.class, new JobExecutionExceptionDeserializer()); setupContext.addDeserializers(simpleDeserializers); }
@Override public void setupModule(final SetupContext context) { final SimpleSerializers serializers = new SimpleSerializers(); serializers.addSerializer(CurrencyUnit.class, new CurrencyUnitSerializer()); serializers.addSerializer(MonetaryAmount.class, new MonetaryAmountSerializer(names, writer, formatFactory)); context.addSerializers(serializers); final SimpleDeserializers deserializers = new SimpleDeserializers(); deserializers.addDeserializer(CurrencyUnit.class, new CurrencyUnitDeserializer()); deserializers.addDeserializer(MonetaryAmount.class, new MonetaryAmountDeserializer<>(amountFactory, names)); // for reading into concrete implementation types deserializers.addDeserializer(Money.class, new MonetaryAmountDeserializer<>(moneyFactory, names)); deserializers.addDeserializer(FastMoney.class, new MonetaryAmountDeserializer<>(fastMoneyFactory, names)); deserializers.addDeserializer(RoundedMoney.class, new MonetaryAmountDeserializer<>(roundedMoneyFactory, names)); context.addDeserializers(deserializers); }
@Override public void setupModule(SetupContext context) { super.setupModule(context); SimpleSerializers serializers = new SimpleSerializers(); SimpleDeserializers deserializers = new SimpleDeserializers(); // java.sql.Time serializers.addSerializer(Time.class, new TimeSerializer()); deserializers.addDeserializer(Time.class, new TimeDeserializer()); // java.sql.Date serializers.addSerializer(Date.class, new SqlDateSerializer()); deserializers.addDeserializer(Date.class, new SqlDateDeserializer()); context.addSerializers(serializers); context.addDeserializers(deserializers); }
@Override public void setupModule(SetupContext context) { context.addSerializers(new SimpleSerializers(Arrays.<JsonSerializer<?>>asList( new GaugeSerializer(timestampFieldname), new CounterSerializer(timestampFieldname), new HistogramSerializer(timestampFieldname), new MeterSerializer(rateUnit, timestampFieldname), new TimerSerializer(rateUnit, durationUnit, timestampFieldname), new BulkIndexOperationHeaderSerializer(timestampFieldname) ))); }
@Override public void setupModule(SetupContext setupContext) { SimpleSerializers serializers = new SimpleSerializers(); addSerializers(serializers); setupContext.addSerializers(serializers); SimpleDeserializers deserializers = new SimpleDeserializers(); addDeserializers(deserializers); setupContext.addDeserializers(deserializers); }
/** * Method called by {@link ObjectMapper} when module is registered. * It is called to let module register functionality it provides, * using callback methods passed-in context object exposes. */ @Override public void setupModule(SetupContext setupContext) { SimpleSerializers serializers = new SimpleSerializers(); addSerializers(serializers); setupContext.addSerializers(serializers); SimpleDeserializers deserializers = new SimpleDeserializers(); addDeserializers(deserializers); setupContext.addDeserializers(deserializers); setupContext.addBeanDeserializerModifier(new KeeperBeanDeserializerModifier()); }
@Override public void setupModule(SetupContext context) { super.setupModule(context); SimpleSerializers serializers= new SimpleSerializers(); serializers.addSerializer(LocalDateTime.class, new LocalDateTimeSerializer()); context.addSerializers(serializers); SimpleDeserializers deserializers = new SimpleDeserializers(); deserializers.addDeserializer(LocalDateTime.class, new LocalDateTimeDeserializer()); context.addDeserializers(deserializers); }
@Override public void setupModule(SetupContext context) { SimpleSerializers serializers = new SimpleSerializers(); SimpleDeserializers deserializers = new SimpleDeserializers(); serializers.addSerializer(DateTime.class, new DateTimeSerializer()); deserializers.addDeserializer(DateTime.class, new DateTimeDeserializer()); context.addSerializers(serializers); context.addDeserializers(deserializers); }
@Test public void testPageModule() throws Exception { PageModuleProvider pmp = new PageModuleProvider(); Module module = pmp.getModule(); assertTrue(module instanceof SimpleModule); Field field = module.getClass().getDeclaredField("_serializers"); field.setAccessible(true); SimpleSerializers simpleSerializers = (SimpleSerializers) field.get(module); field = simpleSerializers.getClass().getDeclaredField("_interfaceMappings"); field.setAccessible(true); HashMap<ClassKey, JsonSerializer<?>> classMappings = (HashMap) field.get(simpleSerializers); assertTrue(classMappings.containsKey(new ClassKey(Page.class))); }
@Override public void setupModule(SetupContext context) { SimpleSerializers serializers = new SimpleSerializers(); serializers.addSerializer(ServiceType.class, new ServiceTypeSerializer()); context.addSerializers(serializers); }
@Override public void setupModule(Module.SetupContext context) { SimpleSerializers serializers = new SimpleSerializers(); SimpleDeserializers deserializers = new SimpleDeserializers(); serializers.addSerializer(ModelObjectInterface.class, new NoJpaSerializer()); serializers.addSerializer(Calendar.class, new CalendarSerializer()); serializers.addSerializer(NList.class, new NListSerializer()); context.addSerializers(serializers); context.addDeserializers(deserializers); }
@Override public void setupModule(SetupContext context) { context.addSerializers(new SimpleSerializers(Arrays.<JsonSerializer<?>>asList( new GaugeSerializer(timestampFieldname, additionalFields), new CounterSerializer(timestampFieldname, additionalFields), new HistogramSerializer(timestampFieldname, additionalFields), new MeterSerializer(rateUnit, timestampFieldname, additionalFields), new TimerSerializer(rateUnit, durationUnit, timestampFieldname, additionalFields), new BulkIndexOperationHeaderSerializer() ))); }
@Override public void setupModule(SetupContext context) { SimpleSerializers serializers = new SimpleSerializers(); serializers.addSerializer(Integer.class, new CustomIntegerSerializer()); context.addSerializers(serializers); }
private void addSerializers(SimpleSerializers serializers) { if(jobParameterDescriptionSerializer != null) { serializers.addSerializer(JobParameterDescription.class, jobParameterDescriptionSerializer); } }
private void addSerializers(SimpleSerializers serializers) { serializers.addSerializer(MimeType.class, new MimeTypeSerializer()); serializers.addSerializer(Keeper.class, new KeeperSerializer()); }
public void setSerializerItems(List<JsonSerializer<?>> serializers) { this.setSerializers(new SimpleSerializers(serializers)); }
@Override public void setupModule(final SetupContext context) { context.addSerializers(new SimpleSerializers(Collections.<JsonSerializer<?>>singletonList(new StdSerializer<SpanWrapper>(SpanWrapper.class) { @Override public void serialize(SpanWrapper span, JsonGenerator gen, SerializerProvider serializers) throws IOException { gen.writeStartObject(); Map<String, Object> parameters = null; for (Map.Entry<String, Object> tag : span.getTags().entrySet()) { if (tag.getKey().startsWith(SpanWrapper.INTERNAL_TAG_PREFIX)) { continue; } if (tag.getKey().startsWith(PARAMETERS_PREFIX)) { if (parameters == null) { parameters = new HashMap<String, Object>(); } parameters.put(tag.getKey().replace(PARAMETERS_PREFIX, ""), tag.getValue()); } else if (tag.getKey().equals(Tags.PEER_HOST_IPV4.getKey()) && tag.getValue() instanceof Integer) { gen.writeStringField(IPV4_STRING, InetAddresses.fromInteger((Integer) tag.getValue()).getHostAddress()); gen.writeStringField("ip", InetAddresses.fromInteger((Integer) tag.getValue()).getHostAddress()); } else if (tag.getKey().equals(Tags.PEER_HOST_IPV6.getKey()) && tag.getValue() instanceof String) { gen.writeStringField("ip", (String) tag.getValue()); } else { gen.writeObjectField(tag.getKey(), tag.getValue()); } } if (parameters != null && !parameters.isEmpty()) { gen.writeArrayFieldStart("parameters"); for (Map.Entry<String, Object> entry : parameters.entrySet()) { gen.writeStartObject(); gen.writeObjectField("key", entry.getKey()); gen.writeObjectField("value", entry.getValue()); gen.writeEndObject(); } gen.writeEndArray(); } // always include error tag so we can have a successful/error filter in Kibana if (!span.getTags().containsKey(Tags.ERROR.getKey())) { gen.writeBooleanField("error", false); } gen.writeStringField("name", span.getOperationName()); gen.writeNumberField("duration_ms", span.getDurationMs()); final String timestamp = StringUtils.timestampAsIsoString(span.getStartTimestampMillis()); gen.writeStringField("@timestamp", timestamp); gen.writeEndObject(); } }))); }
@Override public void setupModule(SetupContext context) { context.addSerializers(new SimpleSerializers(Collections.<JsonSerializer<?>>singletonList(new Metric2RegistrySerializer()))); }