| | |
| | | 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; |
| | |
| | | */ |
| | | @Service |
| | | @Slf4j |
| | | public class CacheGlassSubscriptionCallback implements SubscriptionCallback { |
| | | public class CacheGlassSubscriptionCallback { |
| | | |
| | | @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) { |
| | | |
| | | } |
| | | |
| | | } |
| | | // @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) { |
| | | // |
| | | // } |
| | | // |
| | | // } |
| | | } |