net.sf.mbus4j.master

Class MBusMaster

java.lang.Object

net.sf.mbus4j.master.MBusMaster

All Implemented Interfaces:

Closeable, AutoCloseable, Iterable<GenericDevice>, Sender, JSONSerializable

public class MBusMaster
extends Object
implements Iterable<GenericDevice>, Sender, JSONSerializable, Closeable

Handles the MBus devices connected via inputStream/OutputStream.

Version:

$Id: MBusMaster.java 161 2016-06-07 17:36:28Z arnep $ TODO: Handle multi Resoṕonses ClassXData (connect or chaon them together)

Author:

arnep@users.sourceforge.net

Field Summary

Fields inherited from interface net.sf.mbus4j.devices.Sender

DEFAULT_SEND_TRIES

Constructor Summary

Constructors

Constructor and Description
MBusMaster()

Method Summary

Modifier and Type	Method and Description
boolean	addDevice(GenericDevice device) Deprecated.
void	cancel()
void	clearDevices() Deprecated.
void	close()
int	deviceCount() Deprecated.
int	deviceIndexOf(GenericDevice d) Deprecated.
void	fromJSON(net.sf.json.JSONObject json)
Connection	getConnection()
static DataBlock	getDataBlock(Frame frame, ValueRequestPointLocator locator) Deprecated.
GenericDevice	getDevice(int i) Deprecated.
static GenericDevice	getDevice(Iterable<GenericDevice> deviceList, ValueRequestPointLocator locator) Deprecated.
GenericDevice[]	getDevices() Deprecated.
long	getIdleTime() Idle time is 33 bit periods see M-Bus doc chaper 5.4
long	getLastByteSended()
long	getResponseTimeout() Timeout is 330 bit periods + 50ms see M-Bus doc chaper 5.4 2 times max (256) packet size added
long	getShortResponseTimeout()
Iterator<GenericDevice>	iterator() Deprecated.
Closeable	open()
static MBusMaster	readJsonStream(InputStream is)
UserDataResponse	readResponse(byte address)
UserDataResponse	readResponseBySecondary(int bcdId, String man, Byte version, MBusMedium medium)
void	readValues(ValueRequest<?> requests)
GenericDevice	searchDeviceByAddress(byte address)
GenericDevice[]	searchDevicesByPrimaryAddress() Search by primary address (0..250) 253 is for slave select 254 broadcast addres to all devices
GenericDevice[]	searchDevicesByPrimaryAddress(byte first, byte last)
Collection<GenericDevice>	searchDevicesBySecondaryAddressing()
boolean	selectDevice(int bcdMaskedId, short maskedMan, byte maskedVersion, byte maskedMedium)
boolean	selectDevice(int id, String manufacturer, byte version, MBusMedium medium)
boolean	selectDevice(MBusResponseFramesContainer dev)
Frame	send(Frame frame, int maxTries, long timeout)
Frame	sendInitSlave(byte address)
Frame	sendRequestUserData(byte address)
Map<GenericDevice,Frame>	sendRequestUserData(Map<GenericDevice,MBusAddressing> devices)
Map<GenericDevice,Frame>	sendRequestUserData(MBusAddressing addressing) Deprecated.
Frame	sendSetNewAddress(byte address, byte newAddress)
int	sendSlaveSelect(int bcdMaskedId, short maskedMan, byte maskedVersion, byte maskedMedium)
void	setConnection(Connection conn)
boolean	setPrimaryAddressOfDevice(byte newAddress, int id, String manufacturer, byte version, MBusMedium medium)
boolean	setPrimaryAddressOfDevice(byte newAddress, MBusResponseFramesContainer dev)
net.sf.json.JSONObject	toJSON(JsonSerializeType jsonSerializeType)
Collection<GenericDevice>	widcardSearch(int bcdMaskedId, short bcdMaskedMan, byte bcdMaskedVersion, byte bcdMaskedMedium)
void	writeJsonStream(FileOutputStream os)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

MBusMaster

public MBusMaster()

Method Detail

cancel

public void cancel()

getDevice

@Deprecated
public static GenericDevice getDevice(Iterable<GenericDevice> deviceList,
                                                  ValueRequestPointLocator locator)

Deprecated.

getDataBlock

@Deprecated
public static DataBlock getDataBlock(Frame frame,
                                                 ValueRequestPointLocator locator)

Deprecated.

getConnection

public Connection getConnection()

writeJsonStream

public void writeJsonStream(FileOutputStream os)
                     throws UnsupportedEncodingException,
                            IOException

Throws:

UnsupportedEncodingException

IOException

getLastByteSended

public long getLastByteSended()

Returns:

the lastByteSended

addDevice

@Deprecated
public boolean addDevice(GenericDevice device)

Deprecated.

Parameters:

device -

Returns:

true if the device is not Already in the List Identnumber, Manufacturer and Medium

searchDeviceByAddress

public GenericDevice searchDeviceByAddress(byte address)
                                    throws InterruptedException,
                                           IOException

Throws:

InterruptedException

IOException

deviceIndexOf

@Deprecated
public int deviceIndexOf(GenericDevice d)

Deprecated.

clearDevices

@Deprecated
public void clearDevices()

Deprecated.

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

deviceCount

@Deprecated
public int deviceCount()

Deprecated.

getDevice

@Deprecated
public GenericDevice getDevice(int i)

Deprecated.

getDevices

@Deprecated
public GenericDevice[] getDevices()

Deprecated.

getIdleTime

public long getIdleTime()

Idle time is 33 bit periods see M-Bus doc chaper 5.4

Returns:

getResponseTimeout

public long getResponseTimeout()

Timeout is 330 bit periods + 50ms see M-Bus doc chaper 5.4 2 times max (256) packet size added

Returns:

getShortResponseTimeout

public long getShortResponseTimeout()

iterator

@Deprecated
public Iterator<GenericDevice> iterator()

Deprecated.

Specified by:

iterator in interface Iterable<GenericDevice>

searchDevicesBySecondaryAddressing

public Collection<GenericDevice> searchDevicesBySecondaryAddressing()
                                                             throws IOException,
                                                                    InterruptedException

Throws:

IOException

InterruptedException

searchDevicesByPrimaryAddress

public GenericDevice[] searchDevicesByPrimaryAddress()
                                              throws IOException,
                                                     InterruptedException

Search by primary address (0..250) 253 is for slave select 254 broadcast addres to all devices

Returns:

Throws:

IOException

InterruptedException

searchDevicesByPrimaryAddress

public GenericDevice[] searchDevicesByPrimaryAddress(byte first,
                                                     byte last)
                                              throws IOException,
                                                     InterruptedException

Throws:

IOException

InterruptedException

send

public Frame send(Frame frame,
                  int maxTries,
                  long timeout)
           throws IOException,
                  InterruptedException

Specified by:

send in interface Sender

Throws:

IOException

InterruptedException

sendRequestUserData

@Deprecated
public Map<GenericDevice,Frame> sendRequestUserData(MBusAddressing addressing)
                                                         throws IOException,
                                                                InterruptedException

Deprecated.

Throws:

IOException

InterruptedException

sendInitSlave

public Frame sendInitSlave(byte address)
                    throws IOException,
                           InterruptedException

Throws:

IOException

InterruptedException

sendSetNewAddress

public Frame sendSetNewAddress(byte address,
                               byte newAddress)
                        throws InterruptedException,
                               IOException

Throws:

InterruptedException

IOException

sendRequestUserData

public Frame sendRequestUserData(byte address)
                          throws IOException,
                                 InterruptedException

Throws:

IOException

InterruptedException

sendRequestUserData

public Map<GenericDevice,Frame> sendRequestUserData(Map<GenericDevice,MBusAddressing> devices)
                                             throws IOException,
                                                    InterruptedException

Throws:

IOException

InterruptedException

sendSlaveSelect

public int sendSlaveSelect(int bcdMaskedId,
                           short maskedMan,
                           byte maskedVersion,
                           byte maskedMedium)
                    throws IOException,
                           InterruptedException

Throws:

IOException

InterruptedException

setConnection

public void setConnection(Connection conn)

open

public Closeable open()
               throws IOException

Throws:

IOException

widcardSearch

public Collection<GenericDevice> widcardSearch(int bcdMaskedId,
                                               short bcdMaskedMan,
                                               byte bcdMaskedVersion,
                                               byte bcdMaskedMedium)
                                        throws IOException,
                                               InterruptedException

Throws:

IOException

InterruptedException

readResponseBySecondary

public UserDataResponse readResponseBySecondary(int bcdId,
                                                String man,
                                                Byte version,
                                                MBusMedium medium)
                                         throws IOException,
                                                InterruptedException

Throws:

IOException

InterruptedException

readResponse

public UserDataResponse readResponse(byte address)
                              throws IOException,
                                     InterruptedException

Throws:

IOException

InterruptedException

selectDevice

public boolean selectDevice(int bcdMaskedId,
                            short maskedMan,
                            byte maskedVersion,
                            byte maskedMedium)
                     throws IOException,
                            InterruptedException

Throws:

IOException

InterruptedException

selectDevice

public boolean selectDevice(int id,
                            String manufacturer,
                            byte version,
                            MBusMedium medium)
                     throws IOException,
                            InterruptedException

Throws:

IOException

InterruptedException

setPrimaryAddressOfDevice

public boolean setPrimaryAddressOfDevice(byte newAddress,
                                         MBusResponseFramesContainer dev)
                                  throws IOException,
                                         InterruptedException

Throws:

IOException

InterruptedException

setPrimaryAddressOfDevice

public boolean setPrimaryAddressOfDevice(byte newAddress,
                                         int id,
                                         String manufacturer,
                                         byte version,
                                         MBusMedium medium)
                                  throws IOException,
                                         InterruptedException

Throws:

IOException

InterruptedException

selectDevice

public boolean selectDevice(MBusResponseFramesContainer dev)
                     throws IOException,
                            InterruptedException

Throws:

IOException

InterruptedException

readValues

public void readValues(ValueRequest<?> requests)
                throws IOException,
                       InterruptedException

Throws:

IOException

InterruptedException

readJsonStream

public static MBusMaster readJsonStream(InputStream is)
                                 throws IOException

Throws:

IOException

fromJSON

public void fromJSON(net.sf.json.JSONObject json)

Specified by:

fromJSON in interface JSONSerializable

toJSON

public net.sf.json.JSONObject toJSON(JsonSerializeType jsonSerializeType)

Specified by:

toJSON in interface JSONSerializable