<dependency>
<groupId>org.junit.jupiter</groupId>
<artifactId>junit-jupiter-engine</artifactId>
+ <scope>test</scope>
</dependency>
<dependency>
<groupId>org.assertj</groupId>
<artifactId>assertj-core</artifactId>
+ <scope>test</scope>
</dependency>
<dependency>
<groupId>io.projectreactor</groupId>
<groupId>io.projectreactor.netty</groupId>
<artifactId>reactor-netty</artifactId>
</dependency>
+ <dependency>
+ <groupId>org.junit.jupiter</groupId>
+ <artifactId>junit-jupiter-engine</artifactId>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.assertj</groupId>
+ <artifactId>assertj-core</artifactId>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.mockito</groupId>
+ <artifactId>mockito-core</artifactId>
+ <scope>test</scope>
+ </dependency>
</dependencies>
</project>
import org.onap.dcaegen2.services.sdk.services.hvves.client.producer.api.HvVesProducer;
import org.onap.dcaegen2.services.sdk.services.hvves.client.producer.api.HvVesProducerFactory;
import org.onap.dcaegen2.services.sdk.services.hvves.client.producer.api.options.ProducerOptions;
+import org.onap.dcaegen2.services.sdk.services.hvves.client.producer.impl.encoders.EncodersFactory;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import reactor.netty.tcp.TcpClient;
@Override
protected @NotNull HvVesProducer createProducer(ProducerOptions options) {
TcpClient tcpClient = TcpClient.create()
- .addressSupplier(() -> options.collectorAddresses().head());
+ .addressSupplier(() -> options.collectorAddresses().head());
+ ProducerCore producerCore = new ProducerCore(new EncodersFactory());
if (options.securityKeys() == null) {
LOGGER.warn("Using insecure connection");
} else {
LOGGER.info("Using secure tunnel");
final SslContext ctx = sslFactory.createSecureContext(options.securityKeys()).get();
- tcpClient = tcpClient.secure(ssl-> ssl.sslContext(ctx));
+ tcpClient = tcpClient.secure(ssl -> ssl.sslContext(ctx));
}
- return new HvVesProducerImpl(tcpClient);
+ return new HvVesProducerImpl(tcpClient, producerCore);
}
}
*/
package org.onap.dcaegen2.services.sdk.services.hvves.client.producer.impl;
-import io.netty.buffer.ByteBuf;
-import java.nio.charset.StandardCharsets;
import org.jetbrains.annotations.NotNull;
import org.onap.dcaegen2.services.sdk.services.hvves.client.producer.api.HvVesProducer;
import org.onap.ves.VesEventOuterClass.VesEvent;
import org.reactivestreams.Publisher;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
import reactor.netty.NettyOutbound;
import reactor.netty.tcp.TcpClient;
*/
public class HvVesProducerImpl implements HvVesProducer {
- private static final Logger LOGGER = LoggerFactory.getLogger(HvVesProducerImpl.class);
private final TcpClient tcpClient;
+ private final ProducerCore producerCore;
- HvVesProducerImpl(TcpClient tcpClient) {
+
+ HvVesProducerImpl(TcpClient tcpClient, ProducerCore producerCore) {
this.tcpClient = tcpClient;
+ this.producerCore = producerCore;
}
@Override
public @NotNull Mono<Void> send(Publisher<VesEvent> messages) {
return tcpClient
- .handle((inbound, outbound) -> handle(outbound, messages))
- .connect().then();
+ .handle((in, out) -> handle(messages, out))
+ .connect()
+ .then();
}
- private Publisher<Void> handle(NettyOutbound outbound, Publisher<VesEvent> messages) {
- final Flux<ByteBuf> encodedMessages = Flux.from(messages)
- .map(msg -> {
- LOGGER.debug("Encoding VesEvent '{}'", msg);
- final ByteBuf encodedMessage = outbound.alloc().buffer();
- encodedMessage.writeCharSequence(msg.getCommonEventHeader().getDomain(), StandardCharsets.UTF_8);
- encodedMessage.writeByte(0x0a);
- return encodedMessage;
- });
-
- return outbound.send(encodedMessages).then();
+ private Publisher<Void> handle(Publisher<VesEvent> messages, NettyOutbound outbound) {
+ return outbound
+ .send(producerCore.encode(messages, outbound.alloc()))
+ .then();
}
}
--- /dev/null
+/*
+ * ============LICENSE_START=======================================================
+ * DCAEGEN2-SERVICES-SDK
+ * ================================================================================
+ * Copyright (C) 2019 Nokia. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+package org.onap.dcaegen2.services.sdk.services.hvves.client.producer.impl;
+
+import io.netty.buffer.ByteBuf;
+import io.netty.buffer.ByteBufAllocator;
+import org.onap.dcaegen2.services.sdk.services.hvves.client.producer.impl.encoders.EncodersFactory;
+import org.onap.dcaegen2.services.sdk.services.hvves.client.producer.impl.encoders.ProtobufEncoder;
+import org.onap.dcaegen2.services.sdk.services.hvves.client.producer.impl.encoders.WireFrameEncoder;
+import org.onap.ves.VesEventOuterClass.VesEvent;
+import org.reactivestreams.Publisher;
+import reactor.core.publisher.Flux;
+
+
+/**
+ * @author <a href="mailto:jakub.dudycz@nokia.com">Jakub Dudycz</a>
+ */
+public class ProducerCore {
+
+ private final EncodersFactory encodersFactory;
+
+ public ProducerCore(EncodersFactory encodersFactory) {
+ this.encodersFactory = encodersFactory;
+ }
+
+ public Flux<ByteBuf> encode(Publisher<VesEvent> messages, ByteBufAllocator allocator) {
+ final WireFrameEncoder wireFrameEncoder = encodersFactory.createWireFrameEncoder(allocator);
+ final ProtobufEncoder protobufEncoder = encodersFactory.createProtobufEncoder(allocator);
+ return Flux.from(messages)
+ .map(protobufEncoder::encode)
+ .map(wireFrameEncoder::encode);
+ }
+}
--- /dev/null
+/*
+ * ============LICENSE_START=======================================================
+ * DCAEGEN2-SERVICES-SDK
+ * ================================================================================
+ * Copyright (C) 2019 Nokia. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+package org.onap.dcaegen2.services.sdk.services.hvves.client.producer.impl.encoders;
+
+import io.netty.buffer.ByteBufAllocator;
+
+public class EncodersFactory {
+
+ public ProtobufEncoder createProtobufEncoder(ByteBufAllocator allocator) {
+ return new ProtobufEncoder(allocator);
+ }
+
+ public WireFrameEncoder createWireFrameEncoder(ByteBufAllocator allocator) {
+ return new WireFrameEncoder(allocator);
+ }
+}
--- /dev/null
+/*
+ * ============LICENSE_START=======================================================
+ * DCAEGEN2-SERVICES-SDK
+ * ================================================================================
+ * Copyright (C) 2019 Nokia. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+package org.onap.dcaegen2.services.sdk.services.hvves.client.producer.impl.encoders;
+
+import io.netty.buffer.ByteBuf;
+import io.netty.buffer.ByteBufAllocator;
+import org.onap.ves.VesEventOuterClass.VesEvent;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * @author <a href="mailto:jakub.dudycz@nokia.com">Jakub Dudycz</a>
+ */
+public class ProtobufEncoder {
+
+ private static final Logger LOGGER = LoggerFactory.getLogger(ProtobufEncoder.class);
+ private final ByteBufAllocator allocator;
+
+ public ProtobufEncoder(ByteBufAllocator allocator) {
+ this.allocator = allocator;
+ }
+
+ public ByteBuf encode(VesEvent event) {
+ LOGGER.debug("Encoding VesEvent '{}'", event);
+ return allocator.buffer().writeBytes(event.toByteArray());
+ }
+}
--- /dev/null
+/*
+ * ============LICENSE_START=======================================================
+ * DCAEGEN2-SERVICES-SDK
+ * ================================================================================
+ * Copyright (C) 2019 Nokia. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+package org.onap.dcaegen2.services.sdk.services.hvves.client.producer.impl.encoders;
+
+import io.netty.buffer.ByteBuf;
+import io.netty.buffer.ByteBufAllocator;
+
+/**
+ * @author <a href="mailto:jakub.dudycz@nokia.com">Jakub Dudycz</a>
+ */
+public class WireFrameEncoder {
+
+ private final ByteBufAllocator allocator;
+
+ public WireFrameEncoder(ByteBufAllocator allocator) {
+ this.allocator = allocator;
+ }
+
+ public ByteBuf encode(ByteBuf payload) {
+ final ByteBuf encodedMessage = allocator.buffer();
+ encodedMessage.writeByte(0xAA);
+ encodedMessage.writeBytes(payload);
+ encodedMessage.writeByte(0x0a);
+ return encodedMessage;
+ }
+}
--- /dev/null
+/*
+ * ============LICENSE_START=======================================================
+ * DCAEGEN2-SERVICES-SDK
+ * ================================================================================
+ * Copyright (C) 2019 Nokia. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+package org.onap.dcaegen2.services.sdk.services.hvves.client.producer.impl;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.Mockito.mock;
+import static org.mockito.Mockito.times;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
+import static org.onap.dcaegen2.services.sdk.services.hvves.client.producer.impl.utils.VesEvents.defaultVesEvent;
+
+import io.netty.buffer.ByteBuf;
+import io.netty.buffer.ByteBufAllocator;
+import io.netty.buffer.Unpooled;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.onap.dcaegen2.services.sdk.services.hvves.client.producer.impl.encoders.EncodersFactory;
+import org.onap.dcaegen2.services.sdk.services.hvves.client.producer.impl.encoders.ProtobufEncoder;
+import org.onap.dcaegen2.services.sdk.services.hvves.client.producer.impl.encoders.WireFrameEncoder;
+import org.onap.ves.VesEventOuterClass.VesEvent;
+import reactor.core.publisher.Flux;
+
+/**
+ * @author <a href="mailto:jakub.dudycz@nokia.com">Jakub Dudycz</a>
+ */
+public class ProducerCoreTest {
+
+ private ProducerCore producerCore;
+ private EncodersFactory encodersFactoryMock;
+
+ @BeforeEach
+ public void setUp() {
+ encodersFactoryMock = mock(EncodersFactory.class);
+ producerCore = new ProducerCore(encodersFactoryMock);
+ }
+
+ @Test
+ public void encode_should_encode_message_stream_to_wire_frame() {
+ final WireFrameEncoder wireFrameEncoder = mock(WireFrameEncoder.class);
+ final ProtobufEncoder protobufEncoder = mock(ProtobufEncoder.class);
+ final ByteBuf protoBuffer = Unpooled.copiedBuffer(new byte[3]);
+ final ByteBuf wireFrameBuffer = Unpooled.copiedBuffer(new byte[5]);
+
+ when(protobufEncoder.encode(any(VesEvent.class))).thenReturn(protoBuffer);
+ when(wireFrameEncoder.encode(protoBuffer)).thenReturn(wireFrameBuffer);
+ when(encodersFactoryMock.createProtobufEncoder(ByteBufAllocator.DEFAULT)).thenReturn(protobufEncoder);
+ when(encodersFactoryMock.createWireFrameEncoder(ByteBufAllocator.DEFAULT)).thenReturn(wireFrameEncoder);
+
+ // given
+ final int messageStreamSize = 2;
+ final Flux<VesEvent> messages = Flux.just(defaultVesEvent()).repeat(messageStreamSize - 1);
+
+ // when
+ final ByteBuf lastMessage = producerCore.encode(messages, ByteBufAllocator.DEFAULT).blockLast();
+
+ // then
+ verify(encodersFactoryMock).createProtobufEncoder(ByteBufAllocator.DEFAULT);
+ verify(encodersFactoryMock).createWireFrameEncoder(ByteBufAllocator.DEFAULT);
+ verify(protobufEncoder, times(messageStreamSize)).encode(any(VesEvent.class));
+ verify(wireFrameEncoder, times(messageStreamSize)).encode(protoBuffer);
+
+ assertThat(lastMessage).isNotNull();
+ assertThat(lastMessage).isEqualTo(wireFrameBuffer);
+ }
+}
--- /dev/null
+/*
+ * ============LICENSE_START=======================================================
+ * DCAEGEN2-SERVICES-SDK
+ * ================================================================================
+ * Copyright (C) 2019 Nokia. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+package org.onap.dcaegen2.services.sdk.services.hvves.client.producer.impl.encoders;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+import io.netty.buffer.ByteBufAllocator;
+import org.junit.jupiter.api.Test;
+
+/**
+ * @author <a href="mailto:jakub.dudycz@nokia.com">Jakub Dudycz</a>
+ */
+public class EncodersFactoryTest {
+
+ private final EncodersFactory encodersFactory = new EncodersFactory();
+
+ @Test
+ public void factory_methods_should_create_non_null_encoders_objects() {
+ // when
+ final ProtobufEncoder protobufEncoder = encodersFactory.createProtobufEncoder(ByteBufAllocator.DEFAULT);
+ final WireFrameEncoder wireFrameEncoder = encodersFactory.createWireFrameEncoder(ByteBufAllocator.DEFAULT);
+
+ // then
+ assertThat(protobufEncoder).isNotNull();
+ assertThat(wireFrameEncoder).isNotNull();
+ }
+}
--- /dev/null
+/*
+ * ============LICENSE_START=======================================================
+ * DCAEGEN2-SERVICES-SDK
+ * ================================================================================
+ * Copyright (C) 2019 Nokia. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+package org.onap.dcaegen2.services.sdk.services.hvves.client.producer.impl.encoders;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+import io.netty.buffer.ByteBuf;
+import io.netty.buffer.ByteBufAllocator;
+import org.junit.jupiter.api.Test;
+import org.onap.dcaegen2.services.sdk.services.hvves.client.producer.impl.utils.VesEvents;
+import org.onap.ves.VesEventOuterClass.VesEvent;
+
+public class ProtobufEncoderTest {
+
+ private final ProtobufEncoder protobufEncoder = new ProtobufEncoder(ByteBufAllocator.DEFAULT);
+
+ @Test
+ void todo() {
+ // given
+ final VesEvent message = VesEvents.defaultVesEvent();
+
+ // when
+ final ByteBuf encodedMessage = protobufEncoder.encode(message);
+
+ // then
+ assertThat(encodedMessage.readableBytes()).isGreaterThan(0);
+ }
+}
--- /dev/null
+/*
+ * ============LICENSE_START=======================================================
+ * DCAEGEN2-SERVICES-SDK
+ * ================================================================================
+ * Copyright (C) 2019 Nokia. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+package org.onap.dcaegen2.services.sdk.services.hvves.client.producer.impl.encoders;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+import io.netty.buffer.ByteBuf;
+import io.netty.buffer.ByteBufAllocator;
+import io.netty.buffer.Unpooled;
+import org.junit.jupiter.api.Test;
+
+public class WireFrameEncoderTest {
+
+ private final WireFrameEncoder wireFrameEncoder = new WireFrameEncoder(ByteBufAllocator.DEFAULT);
+
+ @Test
+ void todo() {
+ // given
+ final ByteBuf buffer = Unpooled.buffer(0);
+
+ // when
+ final ByteBuf encodedBuffer = wireFrameEncoder.encode(buffer);
+
+ // then
+ assertThat(encodedBuffer.readableBytes()).isGreaterThan(0);
+ }
+
+}
--- /dev/null
+/*
+ * ============LICENSE_START=======================================================
+ * DCAEGEN2-SERVICES-SDK
+ * ================================================================================
+ * Copyright (C) 2019 Nokia. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+package org.onap.dcaegen2.services.sdk.services.hvves.client.producer.impl.utils;
+
+public enum VesEventDomain {
+ FAULT("fault"),
+ HEARTBEAT("heartbeat"),
+ MEASUREMENT("measurement"),
+ MOBILE_FLOW("mobileFlow"),
+ OTHER("other"),
+ PNF_REGISTRATION("pnfRegistration"),
+ SIP_SIGNALING("sipSignaling"),
+ STATE_CHANGE("stateChange"),
+ SYSLOG("syslog"),
+ THRESHOLD_CROSSING_ALERT("thresholdCrossingAlert"),
+ VOICE_QUALITY("voiceQuality"),
+ PERF3GPP("perf3gpp");
+
+ private String name;
+
+ VesEventDomain(String name) {
+ this.name = name;
+ }
+
+ public String domainName() {
+ return name;
+ }
+}
--- /dev/null
+/*
+ * ============LICENSE_START=======================================================
+ * DCAEGEN2-SERVICES-SDK
+ * ================================================================================
+ * Copyright (C) 2019 Nokia. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+package org.onap.dcaegen2.services.sdk.services.hvves.client.producer.impl.utils;
+
+import com.google.protobuf.ByteString;
+import java.util.UUID;
+import org.onap.ves.VesEventOuterClass.CommonEventHeader;
+import org.onap.ves.VesEventOuterClass.CommonEventHeader.Priority;
+import org.onap.ves.VesEventOuterClass.VesEvent;
+
+public final class VesEvents {
+
+ private VesEvents() {
+ }
+
+ public static VesEvent defaultVesEvent() {
+ return vesEvent(VesEventDomain.PERF3GPP, UUID.randomUUID().toString(), ByteString.EMPTY);
+ }
+
+ public static VesEvent vesEvent(VesEventDomain domain, String id, ByteString eventFields) {
+ return vesEvent(commonEventHeader(domain, id), eventFields);
+ }
+
+ private static VesEvent vesEvent(CommonEventHeader commonEventHeader, ByteString eventFields) {
+ return VesEvent
+ .newBuilder()
+ .setCommonEventHeader(commonEventHeader)
+ .setEventFields(eventFields)
+ .build();
+ }
+
+ private static CommonEventHeader commonEventHeader(
+ VesEventDomain domain,
+ String id
+ ) {
+ return CommonEventHeader.newBuilder()
+ .setVersion("sample-version")
+ .setDomain(domain.domainName())
+ .setSequence(1)
+ .setPriority(Priority.NORMAL)
+ .setEventId(id)
+ .setEventName("sample-event-name")
+ .setEventType("sample-event-type")
+ .setStartEpochMicrosec(100000000)
+ .setLastEpochMicrosec(100000005)
+ .setNfNamingCode("sample-nf-naming-code")
+ .setNfcNamingCode("sample-nfc-naming-code")
+ .setNfVendorName("sample-vendor-name")
+ .setReportingEntityId(ByteString.copyFromUtf8("sample-reporting-entity-id"))
+ .setReportingEntityName("sample-reporting-entity-name")
+ .setSourceId(ByteString.copyFromUtf8("sample-source-id"))
+ .setSourceName("sample-source-name")
+ .setTimeZoneOffset("+1")
+ .setVesEventListenerVersion("7.0.2")
+ .build();
+ }
+}
Code Review / dcaegen2 / services / sdk.git / commitdiff