package com.mes.opccallback;
|
|
import com.mes.milo.model.ReadWriteEntity;
|
import com.mes.milo.runner.subscription.SubscriptionCallback;
|
import com.mes.milo.service.MiloService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.eclipse.milo.opcua.sdk.client.subscriptions.ManagedDataItem;
|
import org.eclipse.milo.opcua.stack.core.types.builtin.DataValue;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
/**
|
* @Author : zhoush
|
* @Date: 2024/10/10 14:13
|
* @Description:
|
*/
|
@Service
|
@Slf4j
|
public class CacheGlassSubscriptionCallback implements SubscriptionCallback {
|
|
@Autowired
|
MiloService miloService;
|
|
@Override
|
public void onSubscribe(ManagedDataItem dataItem, DataValue value) {
|
try {
|
log.info("{}___________{}" + dataItem, value);
|
ReadWriteEntity readWriteEntity = miloService.readFromOpcUa("my.device.x1");
|
log.info("{}___________{}" + readWriteEntity);
|
} catch (Exception e) {
|
|
}
|
|
}
|
}
|
