Hi,

Bjarne Boström said
Hi,

Is the server made with our Java SDK as well or something else? Because the data given by the MonitoredEventItemListener.onEvent comes from the server pretty much as-is.

How is your EventFilter for the MonitoredEventItem made?

Does this happen also if you test with the SampleConsoleClient?  

HI,

My server is made of something else.

Please find the below code I am using .
EventFilter Code ———————–

protected final QualifiedName[] eventFieldNames = { new QualifiedName(“EventType”), new QualifiedName(“Message”),
new QualifiedName(“SourceName”), new QualifiedName(“Time”), new QualifiedName(“Severity”),
new QualifiedName(“ActiveState/Id”), new QualifiedName(“ConditionName”),
new QualifiedName(“ActiveState/EffectiveDisplayName”) };

———————————————————————————-
protected EventFilter createEventFilter(QualifiedName[] eventFields) {

NodeId eventTypeId = Identifiers.BaseEventType;
UnsignedInteger eventAttributeId = Attributes.Value;
String indexRange = null;
SimpleAttributeOperand[] selectClauses = new SimpleAttributeOperand[eventFields.length + 1];
for (int i = 0; i < eventFields.length; i++) {
QualifiedName[] browsePath = createBrowsePath(eventFields[i]);
selectClauses[i] = new SimpleAttributeOperand(eventTypeId, browsePath, eventAttributeId, indexRange);
}
// Add a field to get the NodeId of the event source
selectClauses[eventFields.length] = new SimpleAttributeOperand(eventTypeId, null, Attributes.NodeId, null);
EventFilter filter = new EventFilter();
// Event field selection
filter.setSelectClauses(selectClauses);

// Event filtering: the following sample creates a
// "Not OfType GeneralModelChangeEventType" filter
ContentFilterBuilder fb = new ContentFilterBuilder();

fb.add(FilterOperator.Not, new ElementOperand(UnsignedInteger.valueOf(1)));
final LiteralOperand filteredType = new LiteralOperand(new Variant(Identifiers.GeneralModelChangeEventType));
fb.add(FilterOperator.OfType, filteredType);

filter.setWhereClause(fb.getContentFilter());
return filter;
}

protected QualifiedName[] createBrowsePath(QualifiedName qualifiedName) {
if (!qualifiedName.getName().contains("/")) {
return new QualifiedName[] { qualifiedName };
}
int namespaceIndex = qualifiedName.getNamespaceIndex();
String[] names = qualifiedName.getName().split("/");
QualifiedName[] result = new QualifiedName[names.length];
for (int i = 0; i < names.length; i++) {
result[i] = new QualifiedName(namespaceIndex, names[i]);
}
return result;
}
————————————————————————————————————–

MonitoredEventClass
————————————————————————————————————————
@Component
public class OpcUAEventListner implements MonitoredEventItemListener {

@Autowired
private AlarmService service;

public static List newAlarmList;
static {
System.out.println(“IntializedcList everytime we start the app”);
newAlarmList = new CopyOnWriteArrayList();
}

@Override
public void onEvent(MonitoredEventItem event, Variant[] arg1) {
System.out.println(“————–Alarm Received from Server——————-“);
System.out.println(“Monitored EventItem”+event.getEventFilter().toString()+event.getQueueSize()+event.getSamplingInterval()+event.getFilterResult()+event.getDefaultEventFields());

for (Variant var : arg1) {

var.getValue();
System.out.println(var + “Value”);

}

—————————————————————————————————————————–

Adding Listner to MoniteredEventItem
————————————————————————-
public void readData() throws UnknownHostException, ServiceException, StatusException, URISyntaxException,
SecureIdentityException, IOException, ServiceFaultException, ServiceResultException {
connectionutil = new OPCConnectionUtil();
UaClient client = connectionutil.getUaConnection();
Subscription sub = connectionutil.createSubscription();
client.addSubscription(sub);
NodeId nodeid = getNodeIdforServer(Constants.ALARMFOLDER, client);
EventFilter filter = createEventFilter(eventFieldNames);
MonitoredEventItem eventItem = new MonitoredEventItem(nodeid, filter);

eventItem.setEventListener(new OpcUAEventListner());
sub.addItem(eventItem);
System.out.println(eventItem.getNodeId());

}

————————————————————————————————————
This is my code.
Please review and let me know

Thanks