| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263 |
- """
- Common validation functions
- """
- from pika.compat import basestring
- def require_string(value, value_name):
- """Require that value is a string
- :raises: TypeError
- """
- if not isinstance(value, basestring):
- raise TypeError('%s must be a str or unicode str, but got %r' % (
- value_name,
- value,
- ))
- def require_callback(callback, callback_name='callback'):
- """Require that callback is callable and is not None
- :raises: TypeError
- """
- if not callable(callback):
- raise TypeError('callback %s must be callable, but got %r' % (
- callback_name,
- callback,
- ))
- def rpc_completion_callback(callback):
- """Verify callback is callable if not None
- :returns: boolean indicating nowait
- :rtype: bool
- :raises: TypeError
- """
- if callback is None:
- # No callback means we will not expect a response
- # i.e. nowait=True
- return True
- if callable(callback):
- # nowait=False
- return False
- else:
- raise TypeError('completion callback must be callable if not None')
- def zero_or_greater(name, value):
- """Verify that value is zero or greater. If not, 'name'
- will be used in error message
- :raises: ValueError
- """
- if int(value) < 0:
- errmsg = '{} must be >= 0, but got {}'.format(name, value)
- raise ValueError(errmsg)
|
