diff --git a/mopidy/backends/libspotify/playback.py b/mopidy/backends/libspotify/playback.py
index 58f6ec3a..39c56bf6 100644
--- a/mopidy/backends/libspotify/playback.py
+++ b/mopidy/backends/libspotify/playback.py
@@ -1,30 +1,17 @@
 import logging
-import multiprocessing
 
 from spotify import Link, SpotifyError
 
 from mopidy.backends.base import BasePlaybackController
-from mopidy.utils.process import pickle_connection
 
 logger = logging.getLogger('mopidy.backends.libspotify.playback')
 
 class LibspotifyPlaybackController(BasePlaybackController):
-    def _set_output_state(self, state_name):
-        logger.debug(u'Setting output state to %s ...', state_name)
-        (my_end, other_end) = multiprocessing.Pipe()
-        self.backend.output.process_message({
-            'command': 'set_state',
-            'state': state_name,
-            'reply_to': pickle_connection(other_end),
-        })
-        my_end.poll(None)
-        return my_end.recv()
-
     def _pause(self):
-        return self._set_output_state('PAUSED')
+        return self.backend.output.set_state('PAUSED')
 
     def _play(self, track):
-        self._set_output_state('READY')
+        self.backend.output.set_state('READY')
         if self.state == self.PLAYING:
             self.backend.spotify.session.play(0)
         if track.uri is None:
@@ -33,7 +20,7 @@ class LibspotifyPlaybackController(BasePlaybackController):
             self.backend.spotify.session.load(
                 Link.from_string(track.uri).as_track())
             self.backend.spotify.session.play(1)
-            self._set_output_state('PLAYING')
+            self.backend.output.set_state('PLAYING')
             return True
         except SpotifyError as e:
             logger.warning('Play %s failed: %s', track.uri, e)
@@ -43,12 +30,12 @@ class LibspotifyPlaybackController(BasePlaybackController):
         return self._seek(self.time_position)
 
     def _seek(self, time_position):
-        self._set_output_state('READY')
+        self.backend.output.set_state('READY')
         self.backend.spotify.session.seek(time_position)
-        self._set_output_state('PLAYING')
+        self.backend.output.set_state('PLAYING')
         return True
 
     def _stop(self):
-        result = self._set_output_state('READY')
+        result = self.backend.output.set_state('READY')
         self.backend.spotify.session.play(0)
         return result
diff --git a/mopidy/backends/libspotify/session_manager.py b/mopidy/backends/libspotify/session_manager.py
index f58a32f8..62a3c7dd 100644
--- a/mopidy/backends/libspotify/session_manager.py
+++ b/mopidy/backends/libspotify/session_manager.py
@@ -48,7 +48,6 @@ class LibspotifySessionManager(SpotifySessionManager, threading.Thread):
             playlists.append(
                 LibspotifyTranslator.to_mopidy_playlist(spotify_playlist))
         self.core_queue.put({
-            'to': 'output',
             'command': 'set_stored_playlists',
             'playlists': playlists,
         })
@@ -69,7 +68,7 @@ class LibspotifySessionManager(SpotifySessionManager, threading.Thread):
             sample_type, sample_rate, channels):
         """Callback used by pyspotify"""
         # TODO Base caps_string on arguments
-        caps_string = """
+        capabilites = """
             audio/x-raw-int,
             endianness=(int)1234,
             channels=(int)2,
@@ -78,12 +77,7 @@ class LibspotifySessionManager(SpotifySessionManager, threading.Thread):
             signed=True,
             rate=(int)44100
         """
-        self.output.process_message({
-            'to': 'output',
-            'command': 'deliver_data',
-            'caps': caps_string,
-            'data': bytes(frames),
-        })
+        self.output.deliver_data(capabilites, bytes(frames))
 
     def play_token_lost(self, session):
         """Callback used by pyspotify"""
@@ -97,10 +91,7 @@ class LibspotifySessionManager(SpotifySessionManager, threading.Thread):
     def end_of_track(self, session):
         """Callback used by pyspotify"""
         logger.debug('End of data stream.')
-        self.output.process_message({
-            'to': 'output',
-            'command': 'end_of_data_stream',
-        })
+        self.output.end_of_data_stream()
 
     def search(self, query, connection):
         """Search method used by Mopidy backend"""