public function subscribe() {
		if ($this->name === null) {
			throw new InvalidConfigException(get_class($this)." requires a name!");
		}
		$this->getConnection()->getClient()->subscribe(array($this->name),array($this,"receiveMessage"));
		return $this;
	}